itechart / convtools-ita Goto Github PK

from convtools import conversion as c
from datetime import datetime

c.aggregate(
    c.ReduceFuncs.Array(c.call_func(datetime.strptime, c.this(), "%Y-%m-%d"))
).gen_converter(debug=True)

from convtools import conversion as c

merger = c.aggregate(
    {
        "value1": c.ReduceFuncs.First(
            c.item("value1"), where=c("value1").in_(c.this())
        ),
        "value2": c.ReduceFuncs.First(
            c.item("value2"), where=c("value2").in_(c.this())
        ),
    }
)
c.group_by(c.item("first_id"), c.item("date")).aggregate(
    {
        "first_id": c.item("first_id"),
        "date": c.item("date"),
        "data": c.ReduceFuncs.Array(c.this()).pipe(merger),
    }
).gen_converter(debug=True)

c({
  'address1': c.item('address1'),
  'address2': c.item('address2'),
})

items = [
{ 'address1': '221B Baker Street' },
{ 'address1': '10 Downing Street', 'address2': 'Suite 100'}
]

def test_aggregate_no_init_loops():
    converter = c.aggregate(
        {
            "first_a": c.ReduceFuncs.First(c.item("a"), where=c.item("b") > 0),
            "list_b": c.ReduceFuncs.Array(c.item("b"), where=c.item("a") > 0),
        }
    ).gen_converter(debug=True)
    assert converter(
        [
            {"a": 1, "b": 0},
            {"a": 2, "b": 1},
            {"a": 3, "b": 2},
            {"a": 4, "b": 3},
        ],
    ) == {
        "first_a": 2,
        "list_b": [0, 1, 2, 3],
    }

c({
 "date": c.inline_expr("my_custom_date_formatter({dt})".pass_args(dt=c.item("date")),
}).gen_converter()

c({
 "date": c.inline_expr("from my_library import my_custom_date_formatter\n 
  my_custom_date_formatter({dt})".pass_args(dt=c.item("date")),
}).gen_converter()