Streaming
This module provides APIs relating to streaming analytics. For full documentation with examples, please see the Streaming Analytics documentation.
As of KX Control version 4.2.1, the streamingapi.q
can be loaded into standalone processes.
On startup, it will check which mode is running and create stub functions accordingly.
.sa.pub
Publish data to a stream.
Parameters:
Name | Type | Description |
---|---|---|
uID | long | Stream ID |
data | table | Data |
Example:
data:([] time:.z.p; sym:`$"EUR/USD"; price:3?10.0; src:3?`4);
.sa.pub[10j; data];
.sa.registerfuncs
Register unsubscription and snapshot functions for a streaming analytic name.
Parameters:
Name | Type | Description |
---|---|---|
subF | symbol | Sub function |
unsubF | symbol | Unsub function |
snapF | symbol | Snapshot function |
Example:
.fx.unsub:{ delete from `.fx.subs where id=x };
.fx.snapshot:{ select from .fx.cache where id=x };
.sa.registerfuncs[`.fx.stream; `.fx.unsub; `.fx.snapshot];