CassandraTableSensor
Apache CassandraChecks for the existence of a table in a Cassandra cluster.
Access Instructions
Install the Apache Cassandra provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
tableRequiredTarget Cassandra table. Use dot notation to target a specific keyspace.
cassandra_conn_idThe connection ID to use when connecting to Cassandra cluster
Documentation
Checks for the existence of a table in a Cassandra cluster.
See also
For more information on how to use this operator, take a look at the guide: Waiting for a Table to be created
For example, if you want to wait for a table called ‘t’ to be created in a keyspace ‘k’, instantiate it as follows:
>>> cassandra_sensor = CassandraTableSensor(table="k.t",... cassandra_conn_id="cassandra_default",... task_id="cassandra_sensor")