intelmq.bots.outputs.amqptopic package

Submodules

intelmq.bots.outputs.amqptopic.output module

class intelmq.bots.outputs.amqptopic.output.AMQPTopicOutputBot(*args, **kwargs)

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