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