Google LevelDB 算子

LevelDB 是 Google 编写的一个快速键值存储库,提供从字符串键到字符串值的顺序映射。

注意

要使用 LevelDB 挂钩和算子,必须安装 plyvel。如果你指定额外的 apache-airflow-providers-google[leveldb],它将被安装。

放置键

获取、放置、删除键或写入批处理,使用比较器或 LevelDB 中的不同选项创建数据库,这些操作通过 LevelDBOperator 算子执行。

tests/system/providers/google/leveldb/example_leveldb.py[源代码]

put_key_leveldb_task = LevelDBOperator(
    task_id="put_key_leveldb",
    command="put",
    key=b"another_key",
    value=b"another_value",
    trigger_rule=TriggerRule.ALL_DONE,
)

参考

有关更多信息,请查看

此条目是否有用?