Monitor¶

Captures data integrated to any framework you want: Spark, Flink, or even a Python function.

class driftage.monitor.Monitor(jid: str, password: str, identifier: Optional[str] = None, verify_security: bool = False)¶

An Agent to collect data from sources and send to Analyser. This agent authenticates on XMPP server.

Parameters

jid (str) – Id for XMPP authentication. Ex: user@localhost
password (str) – Password for XMPP authentication.
identifier (Optional[str], optional) – Data identification or agent jid, defaults to None
verify_security (bool, optional) – Security validation with XMPP server, defaults to False.

collect(data: dict)¶

Callback to collect data to be sent as dict.