Class PubsubLocation (0.5.3)

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

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

Inheritance

builtins.object > proto.message.Message > PubsubLocation