intelmq.bots.outputs.amqptopic package

Submodules

intelmq.bots.outputs.amqptopic.output module

class intelmq.bots.outputs.amqptopic.output.AMQPTopicOutputBot(bot_id: str, start: bool = False, sighup_event=None, disable_multithreading: bool = None)

Bases: intelmq.lib.bot.OutputBot

Send events to an AMQP topic exchange. Requires the pika python library

connect_server()

connection_attempts = 3

connection_heartbeat = 3600

connection_host = '127.0.0.1'

connection_port = 5672

connection_vhost = None

content_type = 'application/json'

delivery_mode = 2

exchange_durable = True

exchange_name = None

exchange_type = 'topic'

format_routing_key = False

init()

keep_raw_field = False

message_hierarchical_output = False

message_jsondict_as_string = False

message_with_type = False

password = None

process()

Stop the Bot if cannot connect to AMQP Server after the defined connection attempts

require_confirmation = True

routing_key = None

shutdown()

single_key = False

use_ssl = False

username = None

intelmq.bots.outputs.amqptopic.output.BOT

alias of intelmq.bots.outputs.amqptopic.output.AMQPTopicOutputBot

Module contents