Skip to content

Latest commit

 

History

History
50 lines (38 loc) · 1.95 KB

README.md

File metadata and controls

50 lines (38 loc) · 1.95 KB

supervisor-controller-demo

Simple PHP application to manage supervisors processes

Application is built on the top of pmiroslawski/supervisor-controller-bundle.

The main purpose of that application is to monitor RabbitMQ queue and start extra consumers if number of messages is increasing above specified level (when current number of consumers are not able to consuming all messages). If number of messages is decreasing then according to configured thresholds number of consumers will be decreased as well.

Installation

Clone this reposiotory and copy a .env file to .env.local then:

1.Update settings in .env.local file:

APP_ENV=dev
APP_SECRET=XX
SUPERVISOR_HOST=127.0.0.1
SUPERVISOR_PORT=9001
RABBITMQ_HTTP_API_HOST=http://root:root@127.0.0.1:15672/api/queues/%2F
TELEGRAM_DSN=telegram://TOKEN@default?channel=CHAT_ID

  1. Update queues configuration and set proper thresholds for them in config\packages\bit9_supervisor_controller.yaml

        bit9_supervisor_controller:
        queues:
           - name: messages
             consumer: message_consumer
             numprocs: 50               # run 50 if more than 10000
             thresholds:
                - messages: 100         # run 3 processes if less than 100 elements in queue 
                  num: 3
                - messages: 1000        # run 5 processes if less than 1000 elements in queue 
                  num: 5
                - messages: 10000       # run 10 processes if less than 10000 elements in queue 
                  num: 10

  2. Clear application cache

        ./bin/console cache:clear

  3. Add to the cron below command:

        ./bin/console supervisor:queues:watchdog

Usage

Check pmiroslawski/supervisor-controller-bundle to see more.