RabbitMQ User Registration Agents

Overview

This project automates user registration workflows at UAB using RabbitMQ to route tasks between systems like the web interface, CLI tools, databases, and email services. It ensures tasks like assigning user IDs, validating data, and sending notifications happen in sequence without manual intervention.

Key Components

1. The RegUsr Exchange

• Type: Topic exchange (routes messages using routing_key patterns).
• Purpose: Acts as the central hub for all registration-related messages.

2. Core Scripts

• self_reg_app (Web UI): Starts the process by sending a request<queuename> message with user data.
• create_account.py (CLI): Triggers backend tasks (e.g., UID/GID assignment, email subscriptions).

3. Queues & Their Jobs

4. Data Flow

1. A user submits details via the Web UI (self_reg_app).

2. A request<queuename> message is sent to RegUsr with fields:

   { "username", "queuename", "email", "fullname", "reason" }  
   

3. The system:

   • Assigns UID/GID via SQLite (get next uid gid queue).

   • Validates data with a verify<queuename> message.

   • Sends a completed<queuename> message with success/failure status.

   • Notifies the user and logs the event.

Setup & Usage

Prerequisites

• macOS

• Homebrew

• Python 3.x

Install and Setup RabbitMQ

brew update
brew install rabbitmq

For CentOS, refer to:

• RabbitMQ Role Configuration

• VHost Configuration

Add RabbitMQ to Your PATH

echo 'export PATH="/usr/local/sbin:$PATH"' >> ~/.zshrc
source ~/.zshrc  # Reload your shell to apply changes

install centos steps

https://github.com/jprorama/CRI_XCBC/blob/dev/roles/ohpc_rabbitmq/tasks/main.yaml and the 2 vhosts https://github.com/jprorama/CRI_XCBC/blob/dev/roles/ohpc_add_rabbitmq_agents/tasks/main.yaml

Start RabbitMQ

brew services start rabbitmq

Check RabbitMQ Status

rabbitmqctl status

Create Config File

echo '[{rabbit, [{loopback_users, []}]}].' | sudo tee /etc/rabbitmq/rabbitmq.config
sudo chown rabbitmq:rabbitmq /etc/rabbitmq/rabbitmq.config
sudo chmod 644 /etc/rabbitmq/rabbitmq.config

Restart Service

sudo systemctl restart rabbitmq-server

Access the Management UI

• URL: http://localhost:15672

• Credentials:

  • Username: guest

  • Password: guest

Add Vhost in rabbit_config.py

RABBITMQ = {
    'HOST': 'localhost',
    'PORT': 5672,
    'VHOST': 'adduser',
    'USER': 'reggie',
    'PASSWORD': 'reggie'
}

Add Celery Vhost

rabbitmqctl add_vhost adduser
rabbitmqctl add_user reggie reggie
rabbitmqctl set_permissions -p adduser reggie ".*" ".*" ".*"

WIP Configuration Steps

1. Bind Queues to RegUsr Exchange:
   Use these routing keys:

   • request<queuename>

   • completed<queuename>

   • verify<queuename>
     (Replace <queuename> with your queue’s name, e.g., request_user_reg)

2. Deploy Agents:

   • Run the Web UI (self_reg_app) for user submissions.

   • Execute create_account.py to process tasks (e.g., UID assignment).

3. Monitor Queues:
   Use RabbitMQ’s management UI or CLI tools to check:

   • task_manager for workflow progress.

   • notify user for delivery status of emails/SMS.

Error Handling

• Failures (e.g., duplicate email) are reported in the completed<queuename> message’s errmsg field.

• The user reg event logger tracks all registration attempts. Check logs at /var/log/user_reg.log.