add celery

Author: darjeeling

pythonkr_backend/pythonkr_backend/__init__.py

@@ -0,0 +1,5 @@
+# This will make sure the app is always imported when
+# Django starts so that shared_task will use this app.
+from .celery import app as celery_app
+
+__all__ = ('celery_app',)

pythonkr_backend/pythonkr_backend/celery.py

@@ -0,0 +1,41 @@
+import logfire
+from celery import Celery
+from celery.signals import worker_init, beat_init
+
+app = Celery('proj')
+
+
+# Using a string here means the worker doesn't have to serialize
+# the configuration object to child processes.
+# - namespace='CELERY' means all celery-related configuration keys
+#   should have a `CELERY_` prefix.
+app.config_from_object('django.conf:settings', namespace='CELERY')
+
+# Load task modules from all registered Django apps.
+app.autodiscover_tasks()
+
+
+@worker_init.connect()  
+def init_worker(*args, **kwargs):
+    logfire.configure(service_name="celery-worker")  
+    logfire.instrument_celery()
+
+@beat_init.connect()  
+def init_beat(*args, **kwargs):
+    logfire.configure(service_name="celery-beat")  
+    logfire.instrument_celery()
+
+@app.task
+def add(x: int, y: int):
+    return x + y
+
+add.delay(42, 50)
+
+
+app.conf.beat_schedule = {  
+    "add-every-30-seconds": {
+        "task": "tasks.add",
+        "schedule": 30.0,
+        "args": (16, 16),
+    },
+}

pythonkr_backend/pythonkr_backend/settings/prod.py

@@ -66,4 +66,14 @@
     logfire.configure(environment='prod', service_name="web", service_version=sha_service_version)
     logfire.instrument_django()
     logfire.instrument_system_metrics()
-#logfire.instrument_psycopg('psycopg')
+#logfire.instrument_psycopg('psycopg')
+
+# celery 
+CELERY_BROKER_PASSWORD = os.environ.get("CELERY_PASSWORD","FALSE")
+CELERY_BROKER_USERNAME = os.environ.get("CELERY_USERNAME","FALSE")
+CELERY_BROKER_VHOST = os.environ.get("CELERY_VHOST","FALSE")
+# Celery Configuration Options
+CELERY_TIMEZONE = "Asia/Seoul"
+CELERY_TASK_TRACK_STARTED = True
+CELERY_BROKER_URL = "amqp://userid:password@localhost:port/virtual_host"
+CELERY_TASK_TIME_LIMIT = 30 * 60