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]

在派生此类时重写。

此条目是否有帮助?