Свързани публикации 'celery'
Разбиране на Celery Workers: паралелност, предварително извличане и сърдечни удари
Когато използвате Celery в Python, една от най-важните концепции за разбиране е работникът Celery. Работниците са отговорни за асинхронното изпълнение на задачите и могат да бъдат конфигурирани да обработват задачи по различни начини. В тази публикация в блога ще се потопим по-дълбоко в три ключови концепции, свързани с работещите в Celery: едновременност, предварително извличане и сърдечни удари.
Паралелност
Паралелността се отнася до способността на работника да се справя с..
Свързани въпроси 'celery'
В Python Celery, как да запазя обекти в последователни работни извиквания?
Използвам Celery за автоматизиране на изстъргване на екрана. Използвам Selenium, за да отворя уебдрайвер на Chrome, да манипулирам страницата, да запазя някои данни и след това да премина към следващата страница в опашката. Проблемът е, че той...
3496 изгледи
schedule
19.09.2022
Django + Celery 4 грешни настройки
Използвам Django 1.10 и Celery 4.
Открих течове в документацията на Celery :(
Работната конфигурация е добре направена и работи добре (виждам работника, свързан в RabbitMQ webmin). Но моите задачи не могат да се свържат с RabbitMQ, за да...
1530 изгледи
schedule
17.09.2022
използване на супер в целъри задача
Имам някакъв базов клас като:
class Auto(object):
_year = None
_base_price = None
@classmethod
def calculate_price(cls):
return cls._base_price + 5000 * (2016 - cls._year)
class BMW(Auto):
_year = 2015
_base_price...
323 изгледи
schedule
23.09.2022
Опитайте отново задачите за целина преди тяхното обратно броене
работим с Django v1.10 с celery v4.0.2, rabbitMQ v3.5.7 и flower v0.9.1 и сме доста нови с celery, rabbitMQ и flower.
Има функция x(), която е настроена да опита отново след 7 дни в случай на повреда. Имаме 1000 екземпляра на x, поставени отново...
309 изгледи
schedule
24.09.2022
Какво е разпределена система за съобщения? По-конкретно какво се „разпределя“ в него?
Повсеместно се споменава, че - „Celery е асинхронна опашка от задачи/опашка от задачи, базирана на разпределено предаване на съобщения“ . Въпреки че знам как да използвам работници на Celery и всичко останало. Но дълбоко в себе си не разбирам...
948 изгледи
schedule
01.10.2022
Сесията на SQLAlchemy е изчистена в задачата celery и функцията on_success
Създавам инструмент, който извлича данни от различна база данни, трансформира ги и ги съхранява в моята собствена база данни. Мигрирам от APScheduler към Celery, но се натъкнах на следния проблем:
Използвам клас, който наричам JobRecords , за да...
233 изгледи
schedule
29.09.2022
celery+rabbitmq празна опашка
Използвам целина+заекmq. Не мога да намеря удобен начин за изчистване на опашка в celery+rabbitmq. Правя го с премахване и създаване на vhost.
rabbitmqctl delete_vhost <vhostpath>
rabbitmqctl add_vhost <vhostpath>
Предпочитан...
5465 изгледи
schedule
22.10.2022
Инсталира Celery, но не изпълнява задачи
Използвам уеб услугите на Amazon. И се опитвам да накарам Celery да работи. Опитах се да направя това, което се казва в документацията...
1893 изгледи
schedule
13.10.2022
Настройване на Rabbit MQ Heartbeat с Kombu
Редактиране:
Основният проблем е, че машината rabbitmq на трета страна изглежда убива неактивните връзки от време на време. Тогава започвам да получавам изключения „Спукана тръба“. Единственият начин да получите комуникации. обратно към...
4731 изгледи
schedule
11.11.2023
django celery - изпълнява две опашки в един воркър
Използвам целина за изискванията на моя проект. В момента създадох опашка „HighPriorityQueue“ заедно с опашката по подразбиране, т.е. ще има един работник и две опашки.
Ще има различни задачи, поставени на опашка и в двете опашки. Трябва да...
254 изгледи
schedule
14.10.2022
Да накарате zmq сървър да работи вечно в Django?
Опитвам се да разбера, че най-добрият начин да поддържам zeroMQ слушател да работи завинаги в моето django приложение.
Настройвам zmq сървърно приложение в моя проект Django, което действа като вътрешен API за други приложения в нашата мрежа (няма...
978 изгледи
schedule
16.10.2022
Как да накарам django да изпълни отдалечена задача за целина? Изглежда игнорира BROKER_URL в settings.py
Имам приложение django, което се опитва да извика celery задача, която в крайна сметка ще бъде изпълнена на някои отдалечени хостове. Кодовата база на задачите е напълно отделна от проекта django, така че използвам celery.execute.send_task и го...
894 изгледи
schedule
02.11.2023
премахнете опашката с резултати от rabbitmq с помощта на целина
Изпълнявам tornado-celery и използвам rabbitmq като брокер и изпълнявам същия проблем, вече публикуван на SO question:14636534 , но приетият отговор не отговаря на нуждите ми.
Това, което искам, е да намеря начин да изтрия опашката с резултати,...
1323 изгледи
schedule
16.11.2022
Django: AttributeError: обектът 'bool' няма атрибут 'expire'
В момента използвам модула redis.py на Andy McCurdy, за да взаимодействам с Redis от Django
Прехвърлям определени задачи на заден план с помощта на Celery.
Ето една от задачите ми:
import redis
pool =...
880 изгледи
schedule
15.12.2023
Има опашки за грешки в celery
Има ли някакъв начин в celery, по който, ако изпълнението на задача е неуспешно, мога автоматично да я поставя в друга опашка.
Например, ако задачата се изпълнява в опашка x , при изключение я поставете в друга опашка с име error_x...
1439 изгледи
schedule
16.10.2022
Celery, rabbitmq: Как да инсталирам отдалечен работник?
Мога ли да имам множество машини за изпълнение на задачите и връщане на съобщения, които се разпространяват от django? Разгледах celery/rabbitmq, не съм сигурен дали мога да настроя celery работници на отдалечени компютри. Може ли някой да ме...
1317 изгледи
schedule
19.12.2023
Стартиране на celeryd & celerycam в производство с помощта на супервайзър, който се проваля на AWS
Използвам Bitnami AMI за django проект, който също ще се нуждае от celery и celerycam. Бих искал да използвам supervisor за стартиране и управление на тези услуги, но имам проблем. Конфигурацията за двете е подобна, така че съм поставил само celeryd...
2382 изгледи
schedule
21.12.2023
Асинхронна обработка на опашка от задачи на структура от данни в паметта в Django
Имам единична структура от данни в паметта в моя Django проект (някакво kd-дърво, което трябва да получи достъп в целия проект).
За тези, които не познават Django, вярвам, че същият проблем ще се появи с обикновен код на Python.
Знам, че е зло...
1329 изгледи
schedule
11.11.2022
pymongo колекция обект сериализиране __getnewargs__ метод
Обектът за събиране на Pymongo се проваля, когато се опитвам да изпълня задачите си с целина. Предполагам, че не може да го сериализира. Какво трябва да направя? Между другото опитах туршия, но не ми помогна.
PS: Не искам да правя глобален db...
429 изгледи
schedule
29.11.2023
Django-celina състояние ПОЛУЧЕНО?
Изпълнявам някои задачи чрез django-celery (с rabbitmq като бекенд), задачите отнемат време и интензивно натоварват процесора.
Получих 2 работни екземпляра Ec2 (единият е малък, а другият е среден с висок процесор).
Настроих малкия екземпляр да...
444 изгледи
schedule
04.01.2024
