Publish

Publish a message to a Pub/Sub topic

yaml
type: "io.kestra.plugin.gcp.pubsub.Publish"

yaml
id: gcp_pubsub_publish
namespace: company.team

tasks:
  - id: publish
    type: io.kestra.plugin.gcp.pubsub.Publish
    topic: topic-test
    from:
      - data: "{{ 'base64-encoded-string-1' | base64encode }}"
         attributes:
             testAttribute: KestraTest
      - messageId: '1234'
      - orderingKey: 'foo'
      - data: "{{ 'base64-encoded-string-2' | base64encode }}"
      - attributes:
             testAttribute: KestraTest

Dynamic YES

The source of the published data.

Can be an internal storage URI, a list of Pub/Sub messages, or a single Pub/Sub message.

Dynamic YES

Default STRING

Possible Values

STRINGJSON

The serializer/deserializer to use.

Dynamic YES

The Pub/Sub topic

The Pub/Sub topic. It must be created before executing the task.

Dynamic YES

The GCP service account to impersonate.

Dynamic YES

The GCP project ID.

SubType string

Dynamic YES

Default ["https://www.googleapis.com/auth/cloud-platform"]

The GCP scopes to be used.

Dynamic YES

The GCP service account.

Number of published messages.

SubType string

Dynamic YES

The message attributes map

Dynamic YES

The message data, must be a string if serde type is 'STRING', otherwise a JSON object

If it's a string, it can be a dynamic property otherwise not.

Dynamic YES

The message identifier

Dynamic YES

The message ordering key

​Publish

Publish