Глоссарий¶

ack¶

Сокращение от acknowledged.

cipater¶

Выпуск Celery 3.1 назван в честь песни группы Autechre (http://www.youtube.com/watch?v=OHsaqUr_33Y)

nullipotent¶

описывает функцию, которая будет иметь тот же эффект и давать тот же результат, даже если ее вызвать ноль или несколько раз (без побочных эффектов). Более сильная версия idempotent.

pidbox¶

Почтовый ящик процесса, используемый для реализации команд удаленного управления.

prefetch count¶

Максимальное количество непринятых сообщений, которое может хранить потребитель, и при превышении которого транспорт не должен больше доставлять сообщения этому потребителю. См. Пределы предварительной выборки.

reentrant¶

описывает функцию, которая может быть прервана в середине выполнения (например, аппаратным прерыванием или сигналом), а затем безопасно вызвана снова позже. Реентерабельность - это не то же самое, что idempotence, поскольку возвращаемое значение не обязательно должно быть одинаковым при одинаковых входных данных, и реентерабельная функция может иметь побочные эффекты, если она может быть прервана; идемпотентная функция всегда реентерабельна, но обратное может быть неверно.

бильярд¶

Форк библиотеки мультипроцессорной обработки Python, содержащий улучшения, необходимые для Celery.

выполнение¶

Работники выполняют задание requests.

запрос¶

Сообщения задачи преобразуются в запросы внутри рабочего. Информация о запросе также доступна в качестве context задачи (атрибут task.request).

звонок на¶

Отправляет сообщение задачи, чтобы функция задачи была executed рабочей.

идемпотент¶

Идемпотентность - это математическое свойство, описывающее функцию, которая может быть вызвана несколько раз без изменения результата. Практически это означает, что функцию можно повторять много раз без непредвиденных последствий, но не обязательно без побочных эффектов в чистом смысле (сравните с nullipotent).

Дополнительная информация: https://en.wikipedia.org/wiki/Idempotent

комбу¶

Библиотека обмена сообщениями Python, используемая Celery для отправки и получения сообщений.

контекст¶

Контекст задачи содержит такую информацию, как id задачи, ее аргументы и то, в какую очередь она была доставлена. Доступ к нему можно получить как к атрибуту tasks request. См. Запрос задания

множитель предварительной выборки¶

Для настройки prefetch count используется параметр worker_prefetch_multiplier, который умножается на количество слотов пула (потоков/процессов/зеленых потоков).

несвоевременное подтверждение¶

Задача имеет значение acknowledged после выполнения (как в случае успеха, так и в случае возникновения ошибки), что означает, что задача будет повторно передана другому рабочему в случае, если машина потеряет питание или рабочий экземпляр будет убит в середине выполнения.

Настроен с помощью task_acks_late.

поздний сигнал¶

Сокращенно late acknowledgment

признал¶

Рабочие подтверждают сообщения в знак того, что сообщение было обработано. Если сообщение не подтверждено, оно будет доставлено повторно. Точный момент, когда транзакция считается неудачной, зависит от транспорта. В AMQP транзакция завершается, когда соединение/канал закрывается (или теряется), а в Redis/SQS транзакция завершается через настраиваемое время (<<0 >>>).

применять¶

Первоначально был синонимом call, но используется для обозначения того, что функция выполняется текущим процессом.

раннее предупреждение¶

Сокращенно early acknowledgment

раннее признание¶

Задача acknowledged выполняется точно в срок, что означает, что задача не будет передана другому работнику, если машина потеряет питание или экземпляр работника будет внезапно убит в середине выполнения.

Настроен с помощью task_acks_late.

РАСЧЕТНОЕ ВРЕМЯ ПРИБЫТИЯ¶

«Estimated Time of Arrival», в Celery и Google Task Queue и т.д. используется как термин для обозначения отложенного сообщения, которое не должно обрабатываться до указанного времени ETA. См. Расчетное время прибытия и обратный отсчет.