Logs

cloudify.logs.message_context_from_cloudify_context(ctx)

Build a message context from a CloudifyContext instance

cloudify.logs.message_context_from_workflow_context(ctx)

Build a message context from a CloudifyWorkflowContext instance

cloudify.logs.message_context_from_sys_wide_wf_context(ctx)

Build a message context from a CloudifyWorkflowContext instance

cloudify.logs.message_context_from_workflow_node_instance_context(ctx)

Build a message context from a CloudifyWorkflowNode instance

class cloudify.logs.CloudifyBaseLoggingHandler(ctx, out_func, message_context_builder)

Bases: logging.Handler

A base handler class for writing log messages to RabbitMQ

flush()

emit(record)

class cloudify.logs.CloudifyPluginLoggingHandler(ctx, out_func=None)

Bases: cloudify.logs.CloudifyBaseLoggingHandler

A handler class for writing plugin log messages to RabbitMQ

class cloudify.logs.CloudifyWorkflowLoggingHandler(ctx, out_func=None)

Bases: cloudify.logs.CloudifyBaseLoggingHandler

A Handler class for writing workflow log messages to RabbitMQ

class cloudify.logs.SystemWideWorkflowLoggingHandler(ctx, out_func=None)

Bases: cloudify.logs.CloudifyBaseLoggingHandler

Class for writing system-wide workflow log messages to RabbitMQ

class cloudify.logs.CloudifyWorkflowNodeLoggingHandler(ctx, out_func=None)

Bases: cloudify.logs.CloudifyBaseLoggingHandler

A Handler class for writing workflow nodes log messages to RabbitMQ

cloudify.logs.init_cloudify_logger(handler, logger_name, logging_level=20)

Instantiate an amqp backed logger based on the provided handler for sending log messages to RabbitMQ

Parameters:

• handler – A logger handler based on the context
• logger_name – The logger name
• logging_level – The logging level

Returns:

An amqp backed logger

cloudify.logs.send_workflow_event(ctx, event_type, message=None, args=None, additional_context=None, out_func=None)

Send a workflow event to RabbitMQ

Parameters:

• ctx – A CloudifyWorkflowContext instance
• event_type – The event type
• message – The message
• args – additional arguments that may be added to the message
• additional_context – additional context to be added to the context

cloudify.logs.send_sys_wide_wf_event(ctx, event_type, message=None, args=None, additional_context=None, out_func=None)

Send a workflow event to RabbitMQ

Parameters:

• ctx – A CloudifySystemWideWorkflowContext instance
• event_type – The event type
• message – The message
• args – additional arguments that may be added to the message
• additional_context – additional context to be added to the context

cloudify.logs.send_workflow_node_event(ctx, event_type, message=None, args=None, additional_context=None, out_func=None)

Send a workflow node event to RabbitMQ

Parameters:

• ctx – A CloudifyWorkflowNode instance
• event_type – The event type
• message – The message
• args – additional arguments that may be added to the message
• additional_context – additional context to be added to the context

cloudify.logs.send_plugin_event(ctx, message=None, args=None, additional_context=None, out_func=None)

Send a plugin event to RabbitMQ

Parameters:

• ctx – A CloudifyContext instance
• message – The message
• args – additional arguments that may be added to the message
• additional_context – additional context to be added to the context

cloudify.logs.send_task_event(cloudify_context, event_type, message=None, args=None, additional_context=None, out_func=None)

Send a task event to RabbitMQ

Parameters:

• cloudify_context – a __cloudify_context struct as passed to operations
• event_type – The event type
• message – The message
• args – additional arguments that may be added to the message
• additional_context – additional context to be added to the context

cloudify.logs.populate_base_item(item, message_type)

cloudify.logs.amqp_event_out(event, ctx)

cloudify.logs.amqp_log_out(log, ctx)

cloudify.logs.stdout_event_out(event, ctx=None)

cloudify.logs.stdout_log_out(log, ctx=None)

cloudify.logs.create_event_message_prefix(event)