tests.system.apache.cassandra.example_cassandra_dag

示例 Airflow DAG,用于使用 CassandraTableSensorCassandraRecordSensor 检查 Cassandra Table 和 Records 是否存在。

属性

ENV_ID

DAG_ID

table_sensor

test_run

模块内容

tests.system.apache.cassandra.example_cassandra_dag.ENV_ID[source]
tests.system.apache.cassandra.example_cassandra_dag.DAG_ID = 'example_cassandra_operator'[source]
tests.system.apache.cassandra.example_cassandra_dag.table_sensor[source]
tests.system.apache.cassandra.example_cassandra_dag.test_run[source]

此条目是否有用?