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