Module Contents

class*, 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


param key

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

type key


param value

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

type value


param keys

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

type keys


param values

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

type values


param leveldb_conn_id

type leveldb_conn_id


param create_if_missing

whether a new database should be created if needed

type create_if_missing


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


value from get(str, not bytes, to prevent error in json.dumps in serialize_value in or None(Optional[str])

Return type


Was this entry helpful?