Apache Cassandra 运算符¶

Apache Cassandra 是一个开源的分布式 NoSQL 数据库，当您需要在不牺牲性能的情况下实现可扩展性和高可用性时，可以使用它。它在商用硬件或云基础架构上提供线性可扩展性和容错能力，使其成为关键任务数据的完美平台。它支持多数据中心复制，并具有较低的延迟。

先决条件¶

要使用运算符，您必须配置 Cassandra 连接。

等待创建表¶

CassandraTableSensor 运算符用于检查 Cassandra 集群中是否存在表。

使用 table 参数（在下面的示例中设置在 default_args 中）进行轮询，直到找到提供的表。使用点符号定位特定的键空间。

等待创建记录¶

CassandraRecordSensor 运算符用于检查 Cassandra 集群中是否存在表的记录。

使用 table 参数（在下面的示例中设置在 default_args 中）来提及记录的键空间和表。使用点符号定位特定的键空间。

使用 keys 参数进行轮询，直到找到提供的记录。使用键值对标识记录的存在。在给定的示例中，我们正在寻找列 p1 中的值 v1 和列 p2 中的值 v2。

这些传感器的使用示例¶

tests/system/providers/apache/cassandra/example_cassandra_dag.py[源代码]

with DAG(
    dag_id=DAG_ID,
    schedule=None,
    start_date=datetime(2021, 1, 1),
    default_args={"table": "keyspace_name.table_name"},
    catchup=False,
    tags=["example"],
) as dag:
    table_sensor = CassandraTableSensor(task_id="cassandra_table_sensor")

    record_sensor = CassandraRecordSensor(task_id="cassandra_record_sensor", keys={"p1": "v1", "p2": "v2"})

参考¶

有关更多信息，请参阅 Cassandra 查询语言 (CQL) SELECT 语句。