monasca_log_api.v2.common package

Submodules

monasca_log_api.v2.common.error_handlers module

log_envelope_exception_handler(ex, req, resp, params)

register_error_handlers(app)

monasca_log_api.v2.common.log_publisher module

exception InvalidMessageException

Bases: exceptions.Exception

class LogPublisher

Bases: object

Publishes log data to Kafka

LogPublisher is able to send single message to multiple configured topic. It uses following configuration written in conf file

[log_publisher]
topics = 'logs'
kafka_url = 'localhost:8900'

Note:

Uses monasca_common.kafka.producer.KafkaProducer to ship logs to kafka. For more details see monasca_common github repository.

send_message(messages)

Sends message to each configured topic.

Note:

Falsy messages (i.e. empty) are not shipped to kafka

See also

• monasca_log_api.common.model.Envelope
• _is_message_valid()

Parameters:messages (dict|list) – instance (or instances) of log envelope

monasca_log_api.v2.common.model module

class Envelope(log, meta)

Bases: dict

creation_time

log

meta

classmethod new_envelope(log, tenant_id, region, dimensions=None)

Creates new log envelope

Log envelope is combined ouf of following properties

• log - dict
• creation_time - timestamp
• meta - meta block

Example output json would like this:

{
    "log": {
      "message": "Some message",
      "dimensions": {
        "hostname": "devstack"
      }
    },
    "creation_time": 1447834886,
    "meta": {
      "tenantId": "e4bd29509eda473092d32aadfee3e7b1",
      "region": "pl"
    }
}

Parameters:

• log (dict) – original log element (containing message and other params
• tenant_id (str) – tenant id to be put in meta field
• region (str) – region to be put in meta field
• dimensions (dict) – additional dimensions to be appended to log object dimensions

exception LogEnvelopeException

Bases: exceptions.Exception

monasca_log_api.v2.common.validation module

APPLICATION_TYPE_CONSTRAINTS = {‘MAX_LENGTH’: 255, ‘PATTERN’: <_sre.SRE_Pattern object>}

Application type constraint used in validation.

See Validations.validate_application_type()

DIMENSION_NAME_CONSTRAINTS = {‘MAX_LENGTH’: 255, ‘PATTERN’: <_sre.SRE_Pattern object>}

Constraint for name of single dimension.

See Validations.validate_dimensions()

DIMENSION_VALUE_CONSTRAINTS = {‘MAX_LENGTH’: 255}

Constraint for value of single dimension.

See Validations.validate_dimensions()

validate_application_type(application_type=None)

Validates application type.

Validation won’t take place if application_type is None. For details see: APPLICATION_TYPE_CONSTRAINTS

Parameters:application_type (str) – application type

validate_content_type(req, allowed)

Validates content type.

Method validates request against correct content type.

If content-type cannot be established (i.e. header is missing), falcon.HTTPMissingHeader is thrown. If content-type is not application/json or text/plain, falcon.HTTPUnsupportedMediaType is thrown.

Parameters:

• req (falcon.Request) – current request
• allowed (iterable) – allowed content type

Exception:

falcon.HTTPMissingHeader

Exception:

falcon.HTTPUnsupportedMediaType

validate_cross_tenant(tenant_id, cross_tenant_id, roles)

validate_dimensions(dimensions)

Validates dimensions type.

Empty dimensions are not being validated. For details see:

Parameters:dimensions (dict) – dimensions to validate

• DIMENSION_NAME_CONSTRAINTS
• DIMENSION_VALUE_CONSTRAINTS

validate_is_delegate(role)

validate_log_message(log_object)

Validates log property.

Log property should have message property.

Args:

log_object (dict): log property

validate_payload_size(req)

Validates payload size.

Method validates sent payload size. It expects that http header Content-Length is present. If it does not, method raises falcon.HTTPLengthRequired. Otherwise values is being compared with

[service]
max_log_size = 1048576

max_log_size refers to the maximum allowed content length. If it is exceeded falcon.HTTPRequestEntityTooLarge is thrown.

Parameters:req (falcon.Request) – current request Exception:falcon.HTTPLengthRequired Exception:falcon.HTTPRequestEntityTooLarge