xia_pusher.pusher.Pusher
- class xia_pusher.pusher.Pusher
Bases:
AgentFunctionPusher receive the log data and put it into target
- __init__()
Methods
__init__()push(data_log, agent)Push data to destinations
- address_manager
alias of
DataAddress
- logger_class
alias of
Logger
- model_manager
alias of
DataModel
- classmethod push(data_log: DataLog, agent: Agent)
Push data to destinations
- Parameters
data_log – List of data logs
agent – Agent configuration object
- Returns
id: document id
op: operation type: “I” for insert, “D” for delete, “U” for update, “L” for load
time: time when data is replicated
status: status code of HTTP protocol
- Return type
list of replication results. each result will have the following keys