The monasca_events_api.app.controller.v1.bulk_processor Module

class monasca_events_api.app.controller.v1.bulk_processor.EventsBulkProcessor[source]

Bases: monasca_events_api.app.common.events_publisher.EventPublisher

BulkProcessor for effective events processing and publishing.

BulkProcessor is customized version of monasca_events_api.app.base.event_publisher.EventPublisher that utilizes processing of bulk request inside single loop.

send_message(events, event_project_id=None)[source]

Sends bulk package to kafka

Parameters

  • events (list) – received events

  • event_project_id (str) – project id