monasca_log_api.reference.v3 package

monasca_log_api.reference.v3 module

class Logs

Bases: monasca_log_api.api.logs_api.LogsApi

SUPPORTED_CONTENT_TYPES = set(['application/json'])

VERSION = 'v3.0'

on_post(req, res)

monasca_log_api.reference.v3 module

get_global_dimensions(request_body)

Get the top level dimensions in the HTTP request body.

get_logs(request_body)

Get the logs in the HTTP request body.

read_json_msg_body(req)

Read the json_msg from the http request body and return them as JSON.

Parameters:req – HTTP request object. Returns:Returns the metrics as a JSON object. Raises falcon.HTTPBadRequest:  

class BulkProcessor(logs_in_counter, logs_rejected_counter)

Bases: monasca_log_api.reference.common.log_publisher.LogPublisher

BulkProcessor for effective log processing and publishing.

BulkProcessor is customized version of monasca_log_api.reference.common.log_publisher.LogPublisher that utilizes processing of bulk request inside single loop.

send_message(logs, global_dimensions=None, log_tenant_id=None)

Sends bulk package to kafka

Parameters:

• logs (list) – received logs
• global_dimensions (dict) – global dimensions for each log
• log_tenant_id (str) – tenant who sent logs