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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

from wingfoil import ticker, Graph, build_dataframe

def run_example():
    print("~~~ Single Stream (Primitives) ~~~")
   
    data_a = ticker(0.01).count().limit(5).dataframe()
    data_a.run(realtime=False)
    
    df_prim = data_a.peek_value()
    print(df_prim)
    
    print("\n~~~ Single Stream (Dictionaries) ~~~")
    data_b = (
        ticker(0.01)
        .count()
        .limit(5)
        .map(lambda i: {"price": 100 + i, "qty": 10})
        .dataframe()
    )
    
    data_b.run(realtime=False)
    df_dict = data_b.peek_value()
    print(df_dict)
    
    print("\n~~~ Multiple Streams (Graph + build_dataframe) ~~~")
    
    source = ticker(0.01).count().limit(5)
    
  
    stream_price = source.map(lambda i: 100 + i).dataframe()
    stream_qty = source.map(lambda _: 10).dataframe()
    

    print("Executing Rust Graph engine...")
    Graph([stream_price, stream_qty]).run(realtime=False)
    
    df_zipped = build_dataframe({
        "price": stream_price,
        "qty": stream_qty,
    })
    
    print("Final Aligned DataFrame:")
    print(df_zipped)

if __name__ == "__main__":
    run_example()