Class PubsubLocation (0.8.0)

PubsubLocation(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Identifies a pubsub location to use for transferring data into or out of a streaming Dataflow job.

Attributes

Name	Description
`topic`	`str` A pubsub topic, in the form of "pubsub.googleapis.com/topics/
`subscription`	`str` A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions/
`timestamp_label`	`str` If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.
`id_label`	`str` If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.
`drop_late_data`	`bool` Indicates whether the pipeline allows late-arriving data.
`tracking_subscription`	`str` If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.
`with_attributes`	`bool` If true, then the client has requested to get pubsub attributes.