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]¶

在派生此类时重写。