AsyncAPI channel · Google Cloud Datastream · Google Cloud Datastream CDC Events

`cloud-storage/{bucket}/{rootPath}/{schemaTable}/{yyyy}/{mm}/{dd}/{hh}/{minute}/{objectFile}`

Name: cloud-storage/{bucket}/{rootPath}/{schemaTable}/{yyyy}/{mm}/{dd}/{hh}/{minute}/{objectFile}
Creator: Google Cloud Datastream

Cloud Storage destination path for a Datastream change event file. Datastream organizes data by object and source timestamp. The first folder under the configured root path is [schema]_[table], followed by folders for year, month, day, hour, and minute (the source timestamp from the event metadata). A new folder is created every minute when there is new data. A new file is created when the file si

Open source AsyncAPI → All Google Cloud Datastream channels Google Cloud Datastream provider profile

Provider: Google Cloud Datastream AsyncAPI: v2.6.0 Spec: Google Cloud Datastream CDC Events Operations: 1 Messages: 2

Channel address

cloud-storage/{bucket}/{rootPath}/{schemaTable}/{yyyy}/{mm}/{dd}/{hh}/{minute}/{objectFile}

Parameters

bucket — The Cloud Storage bucket configured on the destination connection profile.
rootPath — The root path prefix configured on the Cloud Storage destination.
schemaTable — Object folder name, formed as [schema]_[table] for database sources.
yyyy — Year derived from the event source timestamp.
mm — Month derived from the event source timestamp.
dd — Day derived from the event source timestamp.
hh — Hour derived from the event source timestamp.
minute — Minute derived from the event source timestamp.
objectFile — Avro (.avro) or JSON (.json) event file written by Datastream. A new file is created when the current file reaches 250 MB or the schema changes.

Operations

receiveCloudStorageCdcEvent

Consume a Datastream CDC event written to Cloud Storage

Messages

DatastreamCdcEventJson

Unified Datastream CDC event written as JSON to Cloud Storage.

Content-Type: application/json

DatastreamCdcEventAvro

Unified Datastream CDC event written as Avro to Cloud Storage. Each column in the payload is represented by its column index and value, with the column name and unified type resolved from the schema i

Content-Type: application/avro

About AsyncAPI

The AsyncAPI specification describes event-driven APIs the way OpenAPI describes request/response APIs. A channel is the named pipe — a webhook URL, a Kafka topic, a WebSocket route, an MQTT subject — that producers and consumers publish or subscribe to. Each channel carries one or more messages with structured payloads, and an operation declares whether a given party sends or receives on that channel.

Browse every event-driven channel on the APIs.io network or compare with the broader Naftiko capability, Agent Skill, and MCP server surfaces of the same providers.