====
Description
Listens to a set of events to update the statistics database.
Data flow
Input
Message clean events
Service catches message clean events to remove old unrelevant pool examples from the database. An important thing here is that even though data might still appear on content insights analytics, it should go away with some time. This is caused by several factors like:
- we need some time to process deletion event from one service to another
- we perform lightweight deletions on a clickhouse that don’t guarantee immediate results
Sender queue events
Service listens to senders queue event to update local MongoDB statistics database with the number of messages for a particular firebase app.
Data then is available via the API (https://statistics.staging.almightypush.com/ui/#!/default/controllers_stock_statistics_senders_monitoring_list_handler) to be used by monitoring systems. The output always represents the current state of messages in the queue for different firebase accounts.
Output
Links
- dependencies: