How to configure redoer.py to send "Info" messages to RabbitMQ

[docktermj]

To have redoer.py send "Info" messages to a RabbitMQ queue...

Use proper subcommand

The proper subcommand to instruct redoer.py to send Info messages to RabbitMQ is redo-withinfo-rabbbitmq.

This can be found by running the following redoer.py "help" command. Example:

$ ./redoer.py --help

usage: redoer.py [-h]
                 {redo,redo-withinfo-kafka,redo-withinfo-rabbitmq,redo-withinfo-sqs,read-from-kafka,read-from-kafka-withinfo,read-from-rabbitmq,read-from-rabbitmq-withinfo,read-from-sqs,read-from-sqs-withinfo,write-to-azure-queue,write-to-kafka,write-to-rabbitmq,write-to-sqs,sleep,version,docker-acceptance-test}
                 ...

Process Senzing redo records. For more information, see https://github.com/Senzing/redoer

positional arguments:
  {redo,redo-withinfo-kafka,redo-withinfo-rabbitmq,redo-withinfo-sqs,read-from-kafka,read-from-kafka-withinfo,read-from-rabbitmq,read-from-rabbitmq-withinfo,read-from-sqs,read-from-sqs-withinfo,write-to-azure-queue,write-to-kafka,write-to-rabbitmq,write-to-sqs,sleep,version,docker-acceptance-test}
                        Subcommands (SENZING_SUBCOMMAND):
    redo                Read Senzing redo records from Senzing SDK and send to G2Engine.process()
    redo-withinfo-kafka
                        Read Senzing redo records from Senzing SDK, send to G2Engine.processWithInfo(), results sent to Kafka.
    redo-withinfo-rabbitmq
                        Read Senzing redo records from Senzing SDK, send to G2Engine.processWithInfo(), results sent to RabbitMQ.
    redo-withinfo-sqs   Read Senzing redo records from Senzing SDK, send to G2Engine.processWithInfo(), results sent to AWS SQS.
    read-from-kafka     Read Senzing redo records from Kafka and send to G2Engine.process()
    read-from-kafka-withinfo
                        Read Senzing redo records from Kafka and send to G2Engine.processWithInfo()
    read-from-rabbitmq  Read Senzing redo records from RabbitMQ and send to G2Engine.process()
    read-from-rabbitmq-withinfo
                        Read Senzing redo records from RabbitMQ and send to G2Engine.processWithInfo()
    read-from-sqs       Read Senzing redo records from AWS SQS and send to G2Engine.process()
    read-from-sqs-withinfo
                        Read Senzing redo records from AWS SQS and send to G2Engine.processWithInfo()
    write-to-azure-queue
                        Read Senzing redo records from Senzing SDK and send to Azure Message Bus queue.
    write-to-kafka      Read Senzing redo records from Senzing SDK and send to Kafka.
    write-to-rabbitmq   Read Senzing redo records from Senzing SDK and send to RabbitMQ.
    write-to-sqs        Read Senzing redo records from Senzing SDK and send to AWS SQS.
    sleep               Do nothing but sleep. For Docker testing.
    version             Print version of program.
    docker-acceptance-test
                        For Docker acceptance testing.

optional arguments:
  -h, --help            show this help message and exit

Find command options / environment variables

The environment variables used to configure redoer.py for sending "info" messages to RabbitMQ are:

• SENZING_RABBITMQ_INFO_EXCHANGE
• SENZING_RABBITMQ_INFO_HOST
• SENZING_RABBITMQ_INFO_PASSWORD
• SENZING_RABBITMQ_INFO_QUEUE
• SENZING_RABBITMQ_INFO_ROUTING_KEY
• SENZING_RABBITMQ_INFO_USERNAME
• SENZING_RABBITMQ_INFO_VIRTUAL_HOST

This information can be found by running the "help" command for the redoer.py redo-withinfo-rabbbitmq subcommand. Example:

$ ./redoer.py redo-withinfo-rabbitmq --help

usage: redoer.py redo-withinfo-rabbitmq [-h] 
                                        [--engine-configuration-json SENZING_ENGINE_CONFIGURATION_JSON]
                                        [--license-base64-encoded SENZING_LICENSE_BASE64_ENCODED]
                                        [--threads-per-read-process SENZING_THREADS_PER_READ_PROCESS]
                                        [--threads-per-process SENZING_THREADS_PER_PROCESS]
                                        [--monitoring-period-in-seconds SENZING_MONITORING_PERIOD_IN_SECONDS]
                                        [--rabbitmq-exchange SENZING_RABBITMQ_EXCHANGE]
                                        [--rabbitmq-heartbeat-in-seconds SENZING_RABBITMQ_HEARTBEAT_IN_SECONDS]
                                        [--rabbitmq-host SENZING_RABBITMQ_HOST] 
                                        [--rabbitmq-password SENZING_RABBITMQ_PASSWORD]
                                        [--rabbitmq-reconnect-delay-in-seconds SENZING_RABBITMQ_RECONNECT_DELAY_IN_SECONDS]
                                        [--rabbitmq-username SENZING_RABBITMQ_USERNAME] 
                                        [--rabbitmq-virtual-host SENZING_RABBITMQ_VIRTUAL_HOST]
                                        [--rabbitmq-use-existing-entities SENZING_RABBITMQ_USE_EXISTING_ENTITIES]
                                        [--rabbitmq-redo-exchange SENZING_RABBITMQ_REDO_EXCHANGE] 
                                        [--rabbitmq-redo-host SENZING_RABBITMQ_REDO_HOST]
                                        [--rabbitmq-redo-password SENZING_RABBITMQ_REDO_PASSWORD] 
                                        [--rabbitmq-redo-queue SENZING_RABBITMQ_REDO_QUEUE]
                                        [--rabbitmq-redo-routing-key SENZING_RABBITMQ_REDO_ROUTING_KEY]
                                        [--rabbitmq-redo-username SENZING_RABBITMQ_REDO_USERNAME]
                                        [--rabbitmq-redo-virtual-host SENZING_RABBITMQ_redo_VIRTUAL_HOST]
                                        [--rabbitmq-info-exchange SENZING_RABBITMQ_INFO_EXCHANGE] 
                                        [--rabbitmq-info-host SENZING_RABBITMQ_INFO_HOST]
                                        [--rabbitmq-info-password SENZING_RABBITMQ_INFO_PASSWORD] 
                                        [--rabbitmq-info-queue SENZING_RABBITMQ_INFO_QUEUE]
                                        [--rabbitmq-info-routing-key SENZING_RABBITMQ_INFO_ROUTING_KEY]
                                        [--rabbitmq-info-username SENZING_RABBITMQ_INFO_USERNAME]
                                        [--rabbitmq-info-virtual-host SENZING_RABBITMQ_INFO_VIRTUAL_HOST]
                                        [--rabbitmq-failure-exchange SENZING_RABBITMQ_FAILURE_EXCHANGE]
                                        [--rabbitmq-failure-host SENZING_RABBITMQ_FAILURE_HOST]
                                        [--rabbitmq-failure-password SENZING_RABBITMQ_FAILURE_PASSWORD]
                                        [--rabbitmq-failure-queue SENZING_RABBITMQ_FAILURE_QUEUE]
                                        [--rabbitmq-failure-routing-key SENZING_RABBITMQ_FAILURE_ROUTING_KEY]
                                        [--rabbitmq-failure-username SENZING_RABBITMQ_FAILURE_USERNAME]
                                        [--rabbitmq-failure-virtual-host SENZING_RABBITMQ_FAILURE_VIRTUAL_HOST]

optional arguments:
  -h, --help            show this help message and exit
  --engine-configuration-json SENZING_ENGINE_CONFIGURATION_JSON
                        Advanced Senzing engine configuration. Default: none
  --license-base64-encoded SENZING_LICENSE_BASE64_ENCODED
                        Base64 encoding of a Senzing license. Default: none
  --threads-per-read-process SENZING_THREADS_PER_READ_PROCESS
                        Number of threads per read process. Default: 1
  --threads-per-process SENZING_THREADS_PER_PROCESS
                        Number of threads per process. Default: 4
  --monitoring-period-in-seconds SENZING_MONITORING_PERIOD_IN_SECONDS
                        Period, in seconds, between monitoring reports. Default: 600
  --rabbitmq-exchange SENZING_RABBITMQ_EXCHANGE
                        RabbitMQ exchange. Default: SENZING_RABBITMQ_EXCHANGE
  --rabbitmq-heartbeat-in-seconds SENZING_RABBITMQ_HEARTBEAT_IN_SECONDS
                        RabbitMQ heartbeat. Default: 60
  --rabbitmq-host SENZING_RABBITMQ_HOST
                        RabbitMQ host. Default: localhost:5672
  --rabbitmq-password SENZING_RABBITMQ_PASSWORD
                        RabbitMQ password. Default: bitnami
  --rabbitmq-reconnect-delay-in-seconds SENZING_RABBITMQ_RECONNECT_DELAY_IN_SECONDS
                        The time (in seconds) to wait between attempts to reconnect to the RabbitMQ broker. Default: 60
  --rabbitmq-username SENZING_RABBITMQ_USERNAME
                        RabbitMQ username. Default: user
  --rabbitmq-virtual-host SENZING_RABBITMQ_VIRTUAL_HOST
                        RabbitMQ virtual host. Default: The RabbitMQ defined default virtual host
  --rabbitmq-use-existing-entities SENZING_RABBITMQ_USE_EXISTING_ENTITIES
                        Connect to an existing exchange and queue using their settings. An error is thrown if the exchange or queue does not exist. If
                        False, it will create the exchange and queue if they do not exist. If they exist, then it will attempt to connect, checking
                        the settings match. Default: True
  --rabbitmq-redo-exchange SENZING_RABBITMQ_REDO_EXCHANGE
                        RabbitMQ exchange. Default: SENZING_RABBITMQ_EXCHANGE
  --rabbitmq-redo-host SENZING_RABBITMQ_REDO_HOST
                        RabbitMQ host. Default: SENZING_RABBITMQ_HOST
  --rabbitmq-redo-password SENZING_RABBITMQ_REDO_PASSWORD
                        RabbitMQ password. Default: SENZING_RABBITMQ_PASSWORD
  --rabbitmq-redo-queue SENZING_RABBITMQ_REDO_QUEUE
                        RabbitMQ queue. Default: senzing-rabbitmq-redo-queue
  --rabbitmq-redo-routing-key SENZING_RABBITMQ_REDO_ROUTING_KEY
                        RabbitMQ routing key. Default: senzing.redo
  --rabbitmq-redo-username SENZING_RABBITMQ_REDO_USERNAME
                        RabbitMQ username. Default: SENZING_RABBITMQ_USERNAME
  --rabbitmq-redo-virtual-host SENZING_RABBITMQ_redo_VIRTUAL_HOST
                        RabbitMQ virtual host. Default: SENZING_RABBITMQ_VIRTUAL_HOST
  --rabbitmq-info-exchange SENZING_RABBITMQ_INFO_EXCHANGE
                        RabbitMQ exchange. Default: SENZING_RABBITMQ_EXCHANGE
  --rabbitmq-info-host SENZING_RABBITMQ_INFO_HOST
                        RabbitMQ host. Default: SENZING_RABBITMQ_HOST
  --rabbitmq-info-password SENZING_RABBITMQ_INFO_PASSWORD
                        RabbitMQ password. Default: SENZING_RABBITMQ_PASSWORD
  --rabbitmq-info-queue SENZING_RABBITMQ_INFO_QUEUE
                        RabbitMQ queue for info. Default: senzing-rabbitmq-info-queue
  --rabbitmq-info-routing-key SENZING_RABBITMQ_INFO_ROUTING_KEY
                        RabbitMQ routing key. Default: senzing.info
  --rabbitmq-info-username SENZING_RABBITMQ_INFO_USERNAME
                        RabbitMQ username. Default: SENZING_RABBITMQ_USERNAME
  --rabbitmq-info-virtual-host SENZING_RABBITMQ_INFO_VIRTUAL_HOST
                        RabbitMQ virtual host. Default: SENZING_RABBITMQ_VIRTUAL_HOST
  --rabbitmq-failure-exchange SENZING_RABBITMQ_FAILURE_EXCHANGE
                        RabbitMQ exchange. Default: SENZING_RABBITMQ_EXCHANGE
  --rabbitmq-failure-host SENZING_RABBITMQ_FAILURE_HOST
                        RabbitMQ host. Default: SENZING_RABBITMQ_HOST
  --rabbitmq-failure-password SENZING_RABBITMQ_FAILURE_PASSWORD
                        RabbitMQ password. Default: SENZING_RABBITMQ_PASSWORD
  --rabbitmq-failure-queue SENZING_RABBITMQ_FAILURE_QUEUE
                        RabbitMQ queue for failures. Default: senzing-rabbitmq-failure-queue
  --rabbitmq-failure-routing-key SENZING_RABBITMQ_FAILURE_ROUTING_KEY
                        RabbitMQ routing key. Default: senzing.failure
  --rabbitmq-failure-username SENZING_RABBITMQ_FAILURE_USERNAME
                        RabbitMQ username. Default: SENZING_RABBITMQ_USERNAME
  --rabbitmq-failure-virtual-host SENZING_RABBITMQ_FAILURE_VIRTUAL_HOST
                        RabbitMQ virtual host. Default: SENZING_RABBITMQ_VIRTUAL_HOST