CassandraTableSensor

Cassandra

Checks for the existence of a table in a Cassandra cluster.

View Source

Last Updated: May. 7, 2021

Access Instructions

Install the Cassandra provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

tablestrTarget Cassandra table. Use dot notation to target a specific keyspace.
cassandra_conn_idstrThe 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")

Was this page helpful?