snowflake.ingest.streaming.ChannelStatus

class ChannelStatus(database_name: str, schema_name: str, pipe_name: str, channel_name: str, status_code: str, latest_committed_offset_token: str | None, created_on_ms: int, rows_inserted: int, rows_parsed: int, rows_error_count: int, last_error_offset_upper_bound: str | None, last_error_message: str | None, last_error_timestamp_ms: int | None, snowflake_avg_processing_latency_ms: int | None, last_refreshed_on_ms: int)

Channel status information returned to users.

Provides access to channel status information including the channel name, status code, and latest committed offset token from Snowflake server.

property database_name: str

Get the database name.

property schema_name: str

Get the schema name.

property pipe_name: str

Get the pipe name.

property channel_name: str

Get the channel name.

Returns:

The name of the channel

Return type:

str

property status_code: str

Get the status code for the channel.

Returns:

The status code from Snowflake server

Return type:

str

property latest_committed_offset_token: str | None

Get the latest committed offset token for the channel.

Returns:

The latest committed offset token, or None if no commits yet

Return type:

Optional[str]

property latest_offset_token: str | None

Get the latest committed offset token for the channel.

Deprecated: Use latest_committed_offset_token instead.

Returns:

The latest committed offset token, or None if no commits yet

Return type:

Optional[str]

property created_on: datetime.datetime

Get the created on timestamp for the channel.

property rows_inserted_count: int

Get the rows inserted for the channel.

property rows_parsed_count: int

Get the rows parsed for the channel.

property rows_error_count: int

Get the rows error count for the channel.

property last_error_offset_token_upper_bound: str | None

Get the last error offset token upper bound for the channel.

property last_error_message: str | None

Get the last error message for the channel.

property last_error_timestamp: datetime.datetime | None

Get the last error timestamp for the channel.

property server_avg_processing_latency: datetime.timedelta | None

Get the snowflake avg processing latency for the channel.

property last_refreshed_on: datetime.datetime

Get the last refreshed on timestamp for the channel.