delete_data_stream()#

relationalai.api
#delete_data_stream(object_fq_name STRING, model_name STRING)

Deletes a data stream from the specified RAI Python model. Models retain access to a snapshot of the most recent data processed by the stream. Requires the cdc_admin application role.

Parameters#

NameTypeDescription
object_fq_nameSTRINGThe fully-qualified name of the data stream’s source table or view in Snowflake, e.g. '<db>.<schema>.<table_or_view>'.
model_nameSTRINGThe name of the model associated with the stream.

Returns#

STRING

Example#

Use api.delete_data_stream() to delete a data stream from a model:

#-- Delete the data stream from the model 'MyModel'. Replace the placeholders with
-- your database, schema, and table or view name.
CALL relationalai.api.delete_data_stream('<db>.<schema>.<table_or_view>', 'MyModel');
/*+-----------------------------------+
  | Data stream deleted successfully. |
  +-----------------------------------+ */
NOTE

When you delete a data stream, RAI Python models retain access to a snapshot of the source data. Queries from models that consume data from a deleted stream are evaluated against the snapshot.

See Data Management for more information data streams.

See Also#