Get Component Instance

Catalyst Data Streams lets you publish live, event-based data through channels and deliver it instantly to subscribed clients. You can create an instance of the Data Streams component to access all channel-level operations such as listing channels, publishing data, and generating WebSocket tokens.

You must first create a Data Streams instance using the datastreams() method to perform any Data Streams operations. The initialize_app() method requires valid Catalyst credentials and app options from credential file or environment variables.

import zcatalyst_sdk
# Initialize SDK (reads credentials + project options)
app_sdk = zcatalyst_sdk.initialize_app()
# Get the Datastreams component
data_streams = app_sdk.datastreams()