airflow.providers.apache.cassandra.sensors.table¶

類¶

CassandraTableSensor

檢查 Cassandra 叢集中是否存在某個表。

模組內容¶

class airflow.providers.apache.cassandra.sensors.table.CassandraTableSensor(*, table, cassandra_conn_id=CassandraHook.default_conn_name, **kwargs)[source]¶

基類: airflow.sensors.base.BaseSensorOperator

檢查 Cassandra 叢集中是否存在某個表。

參見

有關如何使用此 Operator 的更多資訊，請參閱指南：等待表建立

例如，如果您想等待在 keyspace ‘k’ 中建立名為 ‘t’ 的表，可以如下例項化它

>>> cassandra_sensor = CassandraTableSensor(
...     table="k.t", cassandra_conn_id="cassandra_default", task_id="cassandra_sensor"
... )

引數:

table (str) – 目標 Cassandra 表。使用點分表示法指定特定的 keyspace。
cassandra_conn_id (str) – 連線到 Cassandra 叢集時使用的連線 ID

template_fields: collections.abc.Sequence[str] = ('table',)[source]¶

cassandra_conn_id = 'cassandra_default'[source]¶

table[source]¶

poke(context)[source]¶

在派生此類時重寫。