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- rriving 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. |