Registry / database / google-cloud-datastream

google-cloud-datastream

JSON →
library1.19.0pypypi✓ verified 79d ago

Google Cloud Datastream API client library for Python, version 1.19.0. Provides a serverless and change data capture (CDC) service to synchronize data across heterogeneous databases and storage systems. Release cadence is monthly.

pip install google-cloud-datastream
INSTALL
IMPORT
SIG · GOOGLE-CLOUD-DATAS
G
google-cloud-datastream
databasepythonv1.19.0
harness data pending
Install & Compatibility
Where this runs

No compatibility data collected yet for this library.

Code
Verified usage

Verified import paths — ran on the pinned version, not inferred.

DatastreamClient
from google.cloud.datastream_v1 import DatastreamClient
from google.cloud import datastream

Lists all connection profiles in the us-central1 location.

from google.cloud import datastream import google.auth credentials, project = google.auth.default() client = datastream.DatastreamClient(credentials=credentials) parent = f"projects/{project}/locations/us-central1" response = client.list_connection_profiles(parent=parent) print(list(response))
Debug
Known issues
breakingIn v1.x, the library uses gRPC Transport by default. If you need REST transport, you must explicitly set the transport parameter.
fix
client = datastream.DatastreamClient(transport='rest')
affects: >=1.0.0
deprecatedThe old async client class 'DatastreamAsyncClient' is deprecated. Use the synchronous 'DatastreamClient' with asyncio wrappers.
fix
Replace async client with 'async def' calling synchronous client's methods within threads or use the built-in 'await' on the returned grpc future.
affects: 1.15.0+
gotchaMethods like 'create_connection_profile' and 'update_connection_profile' require a 'request_id' parameter for idempotency. Forgetting it may cause duplicate operations on network retry.
fix
Include a unique request_id (e.g. str(uuid.uuid4())) in the request.
affects: all
Upgrade
Version history
1.19.0latest on PyPI · released Jun 3, 2026
Audit
Dependencies
google-api-corerequiredUnderlying HTTP/gRPC transport
proto-plusrequiredProtobuf message handling
Agent activity
6 hits · last 30 days
node
6
Resources
google-cloud-datastream — pip install google-cloud-datastream · libregistry