Skip to content

dp3.scripts.dummy_sender

Simple datapoint sender script for testing local DP3 instance.

batched 

batched(iterable, n)

Batch data into tuples of length n. The last batch may be shorter.

Source code in dp3/scripts/dummy_sender.py 
56
57
58
59
60
61
62
63
def batched(iterable, n):
    """Batch data into tuples of length n. The last batch may be shorter."""
    # batched('ABCDEFG', 3) --> ABC DEF G
    if n < 1:
        raise ValueError("n must be at least one")
    it = iter(iterable)
    while batch := list(islice(it, n)):
        yield batch