PubsubLocation

import type { PubsubLocation } from "https://googleapis.deno.dev/v1/dataflow:v1b3.ts";

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

interface PubsubLocation {

dropLateData?: boolean;

dynamicDestinations?: boolean;

idLabel?: string;

subscription?: string;

timestampLabel?: string;

topic?: string;

trackingSubscription?: string;

withAttributes?: boolean;

}

§Properties

dropLateData?: boolean

Indicates whether the pipeline allows late-arriving data.

dynamicDestinations?: boolean

If true, then this location represents dynamic topics.

idLabel?: string

If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.

subscription?: string

A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions//"

timestampLabel?: string

If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.

topic?: string

A pubsub topic, in the form of "pubsub.googleapis.com/topics//"

trackingSubscription?: string

If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.

withAttributes?: boolean

If true, then the client has requested to get pubsub attributes.