Unable to configure rabbitMq to stackstorm for sensor to listen for new messages #6176
Unanswered
ujjawaldyson
asked this question in
Packs
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
2024-04-02 05:34:12,723 139816291706480 INFO process_container [-] Container shutting down. Invoking cleanup on sensors.
2024-04-02 05:34:13,541 139816138638256 ERROR process_container [-] Process container stopped.
2024-04-02 05:34:13,725 139816291706480 INFO process_container [-] All sensors are shut down.
2024-04-02 05:34:13,745 139816291706480 INFO manager [-] (PID:440044) SensorContainer stopped. Reason - SystemExit
2024-04-02 05:34:14,688 139694813484656 INFO init [-] Connecting to database "st2" @ "127.0.0.1:27017" as user "stackstorm".
2024-04-02 05:34:14,693 139694813484656 INFO init [-] Successfully connected to database "st2" @ "127.0.0.1:27017" as user "stackstorm".
2024-04-02 05:34:14,893 139694813484656 INFO partitioner_lookup [-] Using partitioner default with sensornode sensornode1.
2024-04-02 05:34:14,895 139694813484656 INFO partitioners [-] Found 2 registered sensors in db scan.
2024-04-02 05:34:14,896 139694813484656 INFO manager [-] Setting up container to run 2 sensors.
2024-04-02 05:34:14,896 139694813484656 INFO manager [-] Sensors list - ['linux.FileWatchSensor', 'rabbitmq.RabbitMQQueueSensor'].
2024-04-02 05:34:14,896 139694813484656 INFO manager [-] (PID:546099) SensorContainer started.
2024-04-02 05:34:14,897 139694660416432 INFO process_container [-] Running sensor linux.FileWatchSensor
2024-04-02 05:34:14,906 139694660416432 WARNING api [-] "auth.api_url" configuration option is not configured
2024-04-02 05:34:14,918 139694660416608 INFO mixins [-] Connected to amqp://stackstorm:**@127.0.0.1:5672//
2024-04-02 05:34:14,922 139694660416432 INFO process_container [-] Sensor linux.FileWatchSensor started
2024-04-02 05:34:14,922 139694660416432 INFO process_container [-] Running sensor rabbitmq.RabbitMQQueueSensor
2024-04-02 05:34:14,928 139694660416432 WARNING api [-] "auth.api_url" configuration option is not configured
2024-04-02 05:34:14,952 139694660416432 INFO process_container [-] Sensor rabbitmq.RabbitMQQueueSensor started
2024-04-02 05:34:15,643 140529242270352 INFO sensor_wrapper [-] Found config for sensor "RabbitMQQueueSensor"
2024-04-02 05:34:15,643 140529242270352 INFO sensor_wrapper [-] Watcher started
2024-04-02 05:34:15,643 140529242270352 INFO sensor_wrapper [-] Running sensor initialization code
2024-04-02 05:34:15,644 140566462252480 INFO sensor_wrapper [-] No config found for sensor "FileWatchSensor"
2024-04-02 05:34:15,645 140566462252480 INFO sensor_wrapper [-] Watcher started
2024-04-02 05:34:15,645 140566462252480 INFO sensor_wrapper [-] Running sensor initialization code
2024-04-02 05:34:15,649 140566462252480 INFO sensor_wrapper [-] Running sensor in passive mode
2024-04-02 05:34:15,651 140529242270352 INFO connection_workflow [-] Pika version 1.3.2 connecting to ('20.0.83.91', 5672)
2024-04-02 05:34:15,651 140529242270352 ERROR io_services_utils [-] Socket failed to connect: <eventlet.greenio.base.GreenSocket object at 0x7fcf7b115c40>; error=111 (Connection refused)
2024-04-02 05:34:15,652 140529242270352 ERROR connection_workflow [-] TCP Connection attempt failed: ConnectionRefusedError(111, 'Connection refused'); dest=(<AddressFamily.AF_INET: 2>, <SocketKind.SOCK_STREAM: 1>, 6, '', ('20.0.83.91', 5672))
2024-04-02 05:34:15,652 140529242270352 ERROR connection_workflow [-] AMQPConnector - reporting failure: AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused')
2024-04-02 05:34:15,652 140529242270352 ERROR connection_workflow [-] AMQP connection workflow failed: AMQPConnectionWorkflowFailed: 1 exceptions in all; last exception - AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused'); first exception - None.
2024-04-02 05:34:15,652 140529242270352 ERROR connection_workflow [-] AMQPConnectionWorkflow - reporting failure: AMQPConnectionWorkflowFailed: 1 exceptions in all; last exception - AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused'); first exception - None
2024-04-02 05:34:15,653 140529242270352 ERROR blocking_connection [-] Connection workflow failed: AMQPConnectionWorkflowFailed: 1 exceptions in all; last exception - AMQPConnectorSocketConnectError: ConnectionRefusedError(111, 'Connection refused'); first exception - None
2024-04-02 05:34:15,653 140529242270352 ERROR blocking_connection [-] Error in _create_connection().
Traceback (most recent call last):
File "/opt/stackstorm/st2/lib64/python3.8/site-packages/pika/adapters/blocking_connection.py", line 451, in _create_connection
raise self._reap_last_connection_workflow_error(error)
pika.exceptions.AMQPConnectionError
2024-04-02 05:34:15,654 140529242270352 ERROR (unknown file) [-] Traceback (most recent call last):
2024-04-02 05:34:15,654 140529242270352 ERROR (unknown file) [-] File "/opt/stackstorm/st2/lib/python3.8/site-packages/st2reactor/container/sensor_wrapper.py", line 449, in
2024-04-02 05:34:15,654 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,654 140529242270352 ERROR (unknown file) [-] obj.run()
2024-04-02 05:34:15,654 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,654 140529242270352 ERROR (unknown file) [-] File "/opt/stackstorm/st2/lib/python3.8/site-packages/st2reactor/container/sensor_wrapper.py", line 273, in run
2024-04-02 05:34:15,655 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,655 140529242270352 ERROR (unknown file) [-] self._sensor_instance.setup()
2024-04-02 05:34:15,655 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,655 140529242270352 ERROR (unknown file) [-] File "/opt/stackstorm/packs/rabbitmq/sensors/queues_sensor.py", line 81, in setup
2024-04-02 05:34:15,655 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,655 140529242270352 ERROR (unknown file) [-] self.conn = pika.BlockingConnection(connection_params)
2024-04-02 05:34:15,655 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,656 140529242270352 ERROR (unknown file) [-] File "/opt/stackstorm/st2/lib64/python3.8/site-packages/pika/adapters/blocking_connection.py", line 360, in init
2024-04-02 05:34:15,656 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,656 140529242270352 ERROR (unknown file) [-] self._impl = self._create_connection(parameters, _impl_class)
2024-04-02 05:34:15,656 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,656 140529242270352 ERROR (unknown file) [-] File "/opt/stackstorm/st2/lib64/python3.8/site-packages/pika/adapters/blocking_connection.py", line 451, in _create_connection
2024-04-02 05:34:15,656 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,657 140529242270352 ERROR (unknown file) [-] raise self._reap_last_connection_workflow_error(error)
2024-04-02 05:34:15,657 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,657 140529242270352 ERROR (unknown file) [-] pika.exceptions
2024-04-02 05:34:15,657 140529242270352 ERROR (unknown file) [-] .
2024-04-02 05:34:15,657 140529242270352 ERROR (unknown file) [-] AMQPConnectionError
2024-04-02 05:34:15,657 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,657 140529242270352 ERROR (unknown file) [-]
2024-04-02 05:34:15,657 140529242270352 INFO sensor_wrapper [-] Stopping trigger watcher
2024-04-02 05:34:15,658 140529242270352 INFO sensor_wrapper [-] Invoking cleanup on sensor
2024-04-02 05:34:15,662 140566321027728 INFO mixins [-] Connected to amqp://stackstorm:**@127.0.0.1:5672//
Beta Was this translation helpful? Give feedback.
All reactions