airflow.providers.apache.cassandra.sensors.table¶
类¶
检查 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" ... )
- 参数:
- template_fields: collections.abc.Sequence[str] = ('table',)[source]¶