event¶

Помещает событие во внутреннюю очередь задач (PGQ — PostgreSQL-based queue)

Примечание

Команда вызывает queue.push(event_name, args). Зарегистрированный воркер executor подхватывает событие из очереди и обрабатывает его. Используется как для штатных задач (синхронизация LDAP, чистка кэша), так и для отладки очереди

Зачем нужна¶

Команда позволяет администратору вручную поставить любое именованное событие в очередь задач сервера — то самое, что обычно ставится автоматически по расписанию или по триггерам в коде. Воркер executor подхватит событие и выполнит его

Типичные случаи применения:

немедленный запуск штатных фоновых задач (синхронизация LDAP, очистка кэша, перерасчёт прав) без ожидания планового вызова
разовое выполнение команды из скрипта без необходимости ждать расписания
отладка работоспособности очереди — поставить событие debug и убедиться, что воркер его обработал
обработка инцидентов: «сервер не успевает за нагрузкой» — посмотреть, как очередь отрабатывает добавляемые события

Синтаксис¶

rude event <имя_события> [аргументы в JSON]

Параметры¶

Параметр	Описание
debug	Тестовое событие
session_status	Обновить статус сессии
started	Сигнал о старте
geoadd	Добавить геоданные
sync	Синхронизация
run_report_generation	Запустить генерацию отчёта
run_command	Выполнить команду
run_playbook	Запустить Ansible playbook
run_job	Запустить задание
logevent	Записать событие в лог
notify	Отправить уведомление
sync_ldap_domains_task	Синхронизировать LDAP домен
delete_queryset	Удалить набор объектов
export_queryset	Экспортировать данные
run_inventory_report_collector	Собрать инвентарный отчёт
notify_reports_ready_collector	Уведомить о готовности отчётов
notify_about_ticket	Уведомить о тикете
notify_about_job_finish	Уведомить о завершении задания
flush_server_cache	Очистить кэш сервера
bulk_fetch_logs	Загрузить логи пачкой
run_peer_jobs_after_os_install	Запустить задания после установки ОС
session_record	Записать сессию
generate_manifest	Сгенерировать манифест

Примеры¶

Поместить событие some_task в очередь, где его подхватит воркер и выполнит
rude event some_task arg1 arg2
Очистить весь кэш серверов
rude event flush_server_cache
Синхронизировать LDAP домен
rude event sync_ldap_domains_task
Дебаг (просто проверить что очередь работает)
rude event debug