airflow.providers.google.leveldb.operators.leveldb¶

Classes¶

LevelDBOperator

Execute command in LevelDB.

Module Contents¶

class airflow.providers.google.leveldb.operators.leveldb.LevelDBOperator(*, command, key, value=None, keys=None, values=None, leveldb_conn_id='leveldb_default', name='/tmp/testdb/', create_if_missing=True, create_db_extra_options=None, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Execute command in LevelDB.

See also

For more information on how to use this operator, take a look at the guide: Google LevelDB Operator

param command:: command of plyvel(python wrap for leveldb) for DB object e.g. "put", "get", "delete", "write_batch".
param key:: key for command(put,get,delete) execution(, e.g. b'key', b'another-key')
param value:: value for command(put) execution(bytes, e.g. b'value', b'another-value')
param keys:: keys for command(write_batch) execution(list[bytes], e.g. [b'key', b'another-key'])
param values:: values for command(write_batch) execution e.g. [b'value', b'another-value']
param leveldb_conn_id:
param create_if_missing:: whether a new database should be created if needed
param create_db_extra_options:: extra options of creation LevelDBOperator. See more in the link below Plyvel DB

command[source]¶

key[source]¶

value = None[source]¶

keys = None[source]¶

values = None[source]¶

leveldb_conn_id = 'leveldb_default'[source]¶

name = '/tmp/testdb/'[source]¶

create_if_missing = True[source]¶

create_db_extra_options[source]¶

execute(context)[source]¶

Execute command in LevelDB.

Returns:: value from get(str, not bytes, to prevent error in json.dumps in serialize_value in xcom.py) or str | None
Return type:: str | None