CassandraRecordSensor

Cassandra

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

View Source

Last Updated: Dec. 8, 2020

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.
keysdictThe keys and their values to be monitored
cassandra_conn_idstrThe connection ID to use when connecting to Cassandra cluster

Documentation

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

See also

For more information on how to use this operator, take a look at the guide: Waiting for a Record to be created

For example, if you want to wait for a record that has values ‘v1’ and ‘v2’ for each primary keys ‘p1’ and ‘p2’ to be populated in keyspace ‘k’ and table ‘t’, instantiate it as follows:

>>> cassandra_sensor = CassandraRecordSensor(table="k.t", ... keys={"p1": "v1", "p2": "v2"}, ... cassandra_conn_id="cassandra_default", ... task_id="cassandra_sensor")

Was this page helpful?