Google LevelDB Operator

LevelDB is a fast key-value storage library written at Google that provides an ordered mapping from string keys to string values.

Put key

Get, put, delete key or write_batch, create database with comparator or different options in LevelDB is performed with the LevelDBOperator operator.

airflow/providers/google/leveldb/example_dags/example_leveldb.pyView Source

put_key_leveldb_task = LevelDBOperator(
    task_id='put_key_leveldb',
    leveldb_conn_id='leveldb_default',
    command='put',
    key=b'another_key',
    value=b'another_value',
    dag=dag,
)

Was this entry helpful?