Verplaats je eventdata in realtime

# Maak een stream en begin met het pushen van events
import stroomflow

client = stroomflow.Client(api_key=os.environ["SF_API_KEY"])

stream = client.streams.create(name="orders", format="json")
stream.publish({"order_id": 4815, "total": 162.40})

# Abonneer downstream via een persistente verbinding
for event in stream.subscribe(group="warehouse"):
    warehouse.upsert(event)