wingfoil-python 4.0.1

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
21
22
23
24
25
26
27
28
29
30
31

#!/usr/bin/env python3
"""ZMQ subscriber — direct mode.

Connects to the publisher at ADDRESS. Start zmq_pub.py first.
Cross-language compatible — the Rust publisher works too.

Run publisher and subscriber in separate terminals:

    python examples/zmq/direct/zmq_pub.py
    python examples/zmq/direct/zmq_sub.py
"""

import sys
import wingfoil as wf

ADDRESS = "tcp://127.0.0.1:7779"
print(f"Connecting to {ADDRESS} ... (Ctrl-C to exit)")

data, status = wf.zmq_sub(ADDRESS)

data_node = data.inspect(lambda msgs: [
    print(f"received: {m.decode()}", flush=True) for m in msgs
])

status_node = status.inspect(lambda s: print(f"status: {s}", flush=True))

try:
    wf.Graph([data_node, status_node]).run(realtime=True)
except KeyboardInterrupt:
    print("\nExiting.")
    sys.exit(0)