This page may help you if:
The Event Hose is a part of Momentum 4.x responsible for taking events from the Platform, and passing them onto the Analytics and Webhooks components. See Chapter 1 "Components" in the Momentum 4 Manual . The Event Hose also underlies the Webhook functionality.
The Event Hose is implemented in several components in the Platform:
event_hosemodule, which picks up events from
event_hyrdrant, and injects them into RabbitMQ.
In the event that RabbitMQ is down or does not accept messages, the event_hose module will store event data in
/var/log/ecelerity/event_hose_failed.rt on Platform nodes. The file
event_hose_failed.rt, is a JLog file.
The failed events are not automatically picked up. The
replay_event_hose_failed script must be manually run, to pick up the
replay_event_hose_failed script can also be run on a flat file, with the format of one JSON blob per line. Blank lines are ignored. A flat file could be generated by configuring the
event_hose module to write events to the log aggregation node using the clustering module.
This script only works with Momentum 4.1+. It has been tested with:
Momentum 18.104.22.168 (4.1 HF4)
Step-by-step guide (JLog)
On each Platform node, check whether
On each Platform node that has
/var/log/ecelerity/event_hose_failed.rt, invoke the script.
sudo -u ecuser msys bin/replay_event_hose_failed sudo -u ecuser msys bin/replay_event_hose_failed -l other event_hose_failed.rt
The script will log its progress periodically to STDERR. When it's complete, it will log a summary of records inserted, and records read to STDERR.
The script will checkpoint the JLog after each record. If it is aborted half-way through, it will pick up where it left off when you re-run it on the JLog.
Step-by-step guide (Flat file)
On each Platform node with a flat file invoke the script:
Recommendation: Run under screen or tmux, and capture log lines. Filename required: sudo -u ecuser /opt/msys/ecelerity/bin/replay_event_hose_failed -l /path/to/flat/file
Progress is reported in the same way as for JLogs.