Async jq Operators

pdum.plumbum.jq.async_operators

Attributes

JsonValue module-attribute

JsonValue = JsonScalar | JsonArray | JsonObject

__all__ module-attribute

__all__ = ["aexplode", "aunwind", "agroup_by", "acount_by", "asum_by", "astats"]

Functions

acount_by async

acount_by(stream, expr)

aexplode async

aexplode(iterator, expr, keep_path=False)

agroup_by async

agroup_by(stream, expr)

apb

apb(function)

astats async

astats(stream, expr)

asum_by async

asum_by(stream, key_expr, value_expr, *, default=0.0)

async_iter_operator

async_iter_operator(func)

aunwind async

aunwind(iterator, expr, keep_empty=False)

iter_paths

iter_paths(value, path)

to_async_iterator async

to_async_iterator(stream)

Modules

jq_ops

Attributes

Classes

Functions

coalesce

coalesce(value, *exprs, default=None)

contains

contains(value, expr, needle)

count_by

count_by(iterable, expr)

explode

explode(value, expr, *, keep_path=False)

field

field(value, expr, *, default=None, multi=False, raise_on_missing=False)

flatten

flatten(value, expr=None)

group_by

group_by(iterable, expr)

keys

keys(value, expr=None)

match

match(value, expr, pattern)

merge

merge(value, *exprs)

pick

pick(value, *keys, default=_DEFAULT, **aliases)

pluck

pluck(value, *exprs, as_dict=False, **named_exprs)

project

project(value, expr, pipeline)

remove

remove(value, expr)

set_value

set_value(value, expr, replacement)

stats

stats(iterable, expr)

sum_by

sum_by(iterable, key_expr, value_expr, *, default=0.0)

transform

transform(value, expr, pipeline)

unwind

unwind(value, expr, *, keep_empty=False)

values

values(value, expr=None)

walk

walk(value, expr, pipeline)

where_equals

where_equals(value, expr, expected)

where_exists

where_exists(value, expr)

where_type

where_type(value, expr, expected_type)

zip_fields

zip_fields(value, *exprs, strict=False)