`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)[原始碼]¶

基底類別: airflow.sensors.base.BaseSensorOperator

檢查 Cassandra 集群中是否存在表格。

參見

如需更多關於如何使用此運算子的資訊，請查看指南：等待表格建立

例如，如果您想等待在鍵空間 ‘k’ 中建立名為 ‘t’ 的表格，請按如下方式實例化它

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

參數

table (str) – 目標 Cassandra 表格。使用點表示法來指定特定的鍵空間。
cassandra_conn_id (str) – 連接 Cassandra 集群時要使用的連線 ID

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

poke(context)[原始碼]¶

在衍生此類別時覆寫。

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

模組內容¶

類別¶

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