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

`bigquery/{projectId}/{datasetId}/{tableId}`

Name: bigquery/{projectId}/{datasetId}/{tableId}
Creator: Google Cloud Datastream

BigQuery destination table populated by Datastream. Datastream appends a STRUCT column named datastream_metadata to each replicated table. In merge write mode, datastream_metadata contains UUID and SOURCE_TIMESTAMP (and IS_DELETED for tables without primary keys). In append-only write mode, datastream_metadata additionally contains CHANGE_SEQUENCE_NUMBER, CHANGE_TYPE, and SORT_KEYS for ordering. M

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: 1

Channel address

bigquery/{projectId}/{datasetId}/{tableId}

Parameters

projectId — Google Cloud project hosting the BigQuery dataset.
datasetId — BigQuery dataset ID configured on the destination connection profile.
tableId — BigQuery table ID, derived from the source object name.

Operations

receiveBigQueryCdcRow

Consume a row written to a Datastream-managed BigQuery table

Messages

DatastreamBigQueryRow

A row written to a Datastream-managed BigQuery table. Source row columns are extended with a datastream_metadata STRUCT column whose fields depend on the configured write mode (merge or append-only).

Content-Type: application/json

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.