`tests.system.apache.cassandra.example_cassandra_dag`¶

範例 Airflow DAG，用於檢查 Cassandra 資料表和記錄是否存在，使用 CassandraTableSensor 和 CassandraRecordSensor。

模組內容¶

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

這個條目是否有幫助？