StreamJob

Defined in dccd.daemon.config

class StreamJob(*, exchange, pairs, channels, time_step=60)

Bases: BaseModel

Real-time (WebSocket) data collection job.

Parameters:

exchangestr

Exchange name. Must be one of SUPPORTED_STREAM_EXCHANGES.

pairslist of str

Trading pairs (format depends on exchange).

channelslist of str

WebSocket channels to subscribe to (e.g. ['trades', 'book']).

time_stepint

Snapshot interval in seconds, default is 60.