PhoenixAnalytics.Services.Batcher (PhoenixAnalytics v0.4.1)
View SourceA GenServer module for batching and inserting RequestLog entries into the database.
This module provides functionality to efficiently insert RequestLog entries by batching them and inserting them in bulk. It uses a GenServer to manage the state of the batch and periodically flush the batch to the database.
The batch is processed and inserted into the database either when it reaches 1_000 logs or after 1 second, whichever comes first.
Usage
To insert a RequestLog:
PhoenixAnalytics.Services.Batcher.insert(%PhoenixAnalytics.Entities.RequestLog{})Alternatively, you can send an event to PubSub for request_log insertion:
PhoenixAnalytics.Services.PubSub.broadcast(:request_sent, %PhoenixAnalytics.Entities.RequestLog{})The module will handle batching and inserting the logs automatically. This approach allows for handling distributed app scenarios.
Summary
Functions
Returns a specification to start this module under a supervisor.
Inserts a RequestLog into the batch queue. The batch is processed and inserted into the database either when it reaches 1_000 logs or after 1 second, whichever comes first.
Sends a batch of RequestLogs to be inserted into the database.
Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Inserts a RequestLog into the batch queue. The batch is processed and inserted into the database either when it reaches 1_000 logs or after 1 second, whichever comes first.
Parameters
- request_log: A PhoenixAnalytics.Entities.RequestLog struct to be inserted.
Examples
iex> PhoenixAnalytics.Services.Batcher.insert(%PhoenixAnalytics.Entities.RequestLog{})Note: You can also use PubSub to insert a RequestLog, which is useful for distributed app scenarios:
iex> PhoenixAnalytics.Services.PubSub.broadcast(:request_sent, %PhoenixAnalytics.Entities.RequestLog{})Sends a batch of RequestLogs to be inserted into the database.
Parameters
- batch: A list of PhoenixAnalytics.Entities.RequestLog structs to be inserted.
Examples
iex> PhoenixAnalytics.Services.Batcher.send_batch([%PhoenixAnalytics.Entities.RequestLog{}, %PhoenixAnalytics.Entities.RequestLog{}])