wingfoil-python 3.3.0

python bindings for wingfoil - graph based stream processing framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

#!/usr/bin/env python3

from wingfoil import ticker
import wingfoil

print("wingfoil.__version__=%s" % wingfoil.__version__)

period = 0.1 # seconds

(
    ticker(period)
        .count()
        .map(lambda x: f"hello world {x}")
        .logged(">>")
        .run(
            realtime = True,
            cycles = 3,
        )
)