relationalai.api.resume_data_stream()
resume_data_stream(object_fq_name STRING, model_name STRING)
Resumes a suspended or quarantined data stream for the specified RAI Python model.
Requires the cdc_admin
application role.
Parameters
Section titled “Parameters”Name | Type | Description |
---|---|---|
object_fq_name | STRING | The fully-qualified name of the source table or view in Snowflake, e.g. '<db>.<schema>.<table_or_view>' . |
model_name | STRING | The name of the model associated with the stream. |
Returns
Section titled “Returns”STRING
Example
Section titled “Example”Use api.resume_data_stream()
to resume a suspended or quarantined data stream for a RAI Python model.
-- Resume the data stream for the model 'MyModel'. Replace the placeholders with-- your database, schema, and table or view name.CALL relationalai.my_schema.resume_data_stream('<db>.<schema>.<table_or_view>', 'MyModel');/*+---------------------+ | Data stream resumed | +---------------------+ */
See Data Management for more information on data streams.