get_data_stream()#
relationalai.<rai_schema>
#get_data_stream(<source_table_name>)
Retrieves the status of a specified Change Data Capture (CDC) data stream within a specified RelationalAI (RAI) schema.
Provides information on the stream’s health and data synchronization status.
Requires the <rai_schema>_cdc application role.
Parameters#
| Name | Type | Description |
|---|---|---|
<source_table_name> | STRING | The fully qualified name of the source table or view in Snowflake. |
Example#
Use get_data_stream() to retrieve the status of a CDC data stream within a specified RAI schema.
Replace <source_db>.<source_schema>.<table_or_view_name> with the fully-qualified name of the source table or view.
For example, to get the status of a stream for the table my_table in the schema my_schema:
#CALL relationalai.my_schema.get_data_stream('source_db.source_schema.my_table');