pyloggr.main.shipper2pgsql

Ship events to a PostgreSQL database

class PostgresqlShipper(rabbitmq_config, pgsql_config)

Bases: object

PostgresqlShipper retrieves events from RabbitMQ, and inserts them in PostgreSQL

launch(*args, **kwargs)

Starts the shipper

• Opens a connection to RabbitMQ
• Opens a pool to PostgreSQL
• Consumes messages from RabbitMQ
• Parses messages as regular syslog events
• Periodically ships the events to PostgreSQL

shutdown(*args, **kwargs)

Shutdowns (stops definitely) the shipper.

stop(*args, **kwargs)

Stops the shipper