`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 集群中是否存在表。

另请参阅

有关如何使用此操作符的更多信息，请参阅指南：等待表被创建

例如，如果您想等待一个名为 't' 的表在键空间 'k' 中被创建，请按如下方式实例化它

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