Cześć wszystkim, może ktoś szuka lub zna firmę która poszukuje mid python dev na część etatu(około 20h/tyg). Mam 4 lata doświadczenia, tech stack: python, django, celery, postgresql, docker, redis. Zapraszam na priv :)
#python #django #celery
Robię apkę na django w ramach treningu i dodatkowo chciałem użyć celery do wykonania harmonogramu. Zainstalowałem celery i redisa. Skorzystałem z biblioteki django celery beats. Dodałem prosty task który ma wyprintować tekst. Nie mam pojęcia dlaczego on się nie pojawia chociaż widzę że task się wykonuje bo na konsoli od celery.

[2019-08-24 10:40:09,880: INFO/MainProcess] Scheduler: Sending due task Testowy (robot.tasks.send_notifiction)
Tutaj kod z tasks.py

from __future__ import absolute_import, unicode_literals

from celery import
ok, miałem podwójnie włączony kontener celery worker i celery beat i odpalało task 2x ( ͡° ͜ʖ ͡°)( ͡° ͜ʖ ͡°), odpaliłem z --remove-orphans i jest ok
  • Odpowiedz
Mireczki potrzebuje pomocy z konfiguracją #celery #rabbitmq #supervisor #django #python
Miałem sobie na serwerze jedną apkę w #django z taskami #celery na #rabbitmq, celery odpalane przez #supervisor i wszystko działało jak należy. Dołożyłem kolejną apkę w django zachowując ten sam schemat konfiguracji i działa, tylko zaczęły się problemy. Taski z jednej trafiają czasem do drugiej i odwrotnie.

konfiguracją celery.py 1 apki:

import os
from celery import Celery
from django.conf import settings
@svs_svs: średnio się znam, ale może trzeba zdefiniować osobne kolejki

A worker instance can consume from any number of queues. By default it will consume from all queues defined in the task_queues setting (that if not specified falls back to the default queue named celery).


http://docs.celeryproject.org/en/latest/userguide/workers.html#queues
https://stackoverflow.com/questions/19853378/how-to-keep-multiple-independent-celery-queues
  • Odpowiedz
Takie pytanie zwiazane z #python #celery #redis . Potrzebuje dosc wydajnego przetwarzania requestow od clienta. Ja to widze tak: Przychodzi request ktory sprowadza sie tylko do dodania/zaktualizowania wpisu w bazie danych.
Jak powinnienem synchronizowac redisa z baza danych? Nie synchronizowac wogole tylko np robic task np. za pomoca celery ktory bedzie zapisywal dane rownolegle do bazy? Czy np. co jakis okres czasu odpalac task celery ktory zapisze wszystko z redisa do bazy
Mireczki mam pytanie do jakiegos ogarniacza z #programowanie #python #celery. Mam problem ze stabilnoscia aplikacji. Tworze aplikacje oblugujaca wysylanie i odbieranie wiadomosci pewnej aplikacji. Korzystam z zewnetrznej biblioteki dla tego protokolu. Do dzialania potrzebuje stworzyc dwie petle. Jedna #!$%@? protokol a druga (w odzielnym watku) wysylajaca wiadomosci. Wrzucam to wszystko w task celery. Aby uruchomic nasluchiwanie dla jednego konta uruchamiam (nieskonczony) task. Niestety po pewnym czasie serwer sie zapycha i calosc