airflow.providers.google.leveldb.operators.leveldb

Module Contents

class airflow.providers.google.leveldb.operators.leveldb.LevelDBOperator(*, command: str, key: bytes, value: bytes = None, keys: List[bytes] = None, values: List[bytes] = None, leveldb_conn_id: str = 'leveldb_default', name: str = '/tmp/testdb/', create_if_missing: bool = True, create_db_extra_options: Optional[Dict[str, Any]] = 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".

type command

str

param key

key for command(put,get,delete) execution(, e.g. b'key', b'another-key')

type key

bytes

param value

value for command(put) execution(bytes, e.g. b'value', b'another-value')

type value

bytes

param keys

keys for command(write_batch) execution(List[bytes], e.g. [b'key', b'another-key'])

type keys

List[bytes]

param values

values for command(write_batch) execution e.g. [b'value', b'another-value']

type values

List[bytes]

param leveldb_conn_id

type leveldb_conn_id

str

param create_if_missing

whether a new database should be created if needed

type create_if_missing

bool

param create_db_extra_options

extra options of creation LevelDBOperator. See more in the link below Plyvel DB

type create_db_extra_options

Optional[Dict[str, Any]]

execute(self, 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 None(Optional[str])

Return type

Optional[str]

Was this entry helpful?