add

celerybeat.pid

+9640

injection/data_sync/tasks.py

@@ -34,6 +34,7 @@ def write_to_es(es_type, pk_list, use_batch_query_set=False):
 @shared_task
 def sync_face_similar_data_to_redis():
     try:
+        logging.info("get into sync_face_similar_data_to_redis")
         result_items = FaceUserContrastSimilar.objects.filter(is_online=True, is_deleted=False).distinct().values(
             "participant_user_id").values_list("participant_user_id", flat=True)
 

physical/__init__.py

@@ -4,4 +4,4 @@ import pymysql
 from .celery import app as celery_app
 
 pymysql.install_as_MySQLdb()
-__all__ = ('celery_app',)
+# __all__ = ['celery_app',]

physical/celery.py

@@ -15,7 +15,7 @@ app = Celery('physical')
 app.config_from_object('django.conf:settings', namespace='CELERY')
 
 # Load task modules from all registered Django app configs.
-app.autodiscover_tasks()
+app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
 app.conf.broker_url = settings.CELERY_BROKER_URL
 
 

physical/settings.py

@@ -39,25 +39,26 @@ BROKER_URL = "redis://127.0.0.1:6379/8"
 CELERY_DEFAULT_EXCHANGE = 'celery'
 CELERY_DEFAULT_EXCHANGE_TYPE = 'direct'
 CELERY_DEFAULT_ROUTING_KEY = 'celery'
-CELERY_IMPORTS = ('injection.data_sync.tasks', )
-#
-# CELERY_QUEUES = {
-#     'celery': {
-#         'exchange': CELERY_DEFAULT_EXCHANGE,
-#         'routing_key': CELERY_DEFAULT_ROUTING_KEY,
-#     },
-#     'order': {
-#         'exchange': 'order',
-#         'routing_key': 'order',
-#     },
-# }
+CELERY_IMPORTS = ('injection.data_sync.tasks',)
+
+
+CELERY_QUEUES = {
+    'celery': {
+        'exchange': CELERY_DEFAULT_EXCHANGE,
+        'routing_key': CELERY_DEFAULT_ROUTING_KEY,
+    },
+    'order': {
+        'exchange': 'order',
+        'routing_key': 'order',
+    },
+}
+
+
 CELERY_BROKER_URL = "redis://127.0.0.1:6379/8"
 CELERY_TIMEZONE = 'Asia/Shanghai'
 CELERY_ROUTES = ['physical.celery_task_router.CeleryTaskRouter']
 CELERY_RESULT_SERIALIZER = 'json'  # 结果序列化方案
-CELERY_IMPORTS = ('injection.data_sync.tasks', )
-
-
+CELERY_IMPORTS = ('injection.data_sync.tasks',)
 
 INSTALLED_APPS = (
     'django.contrib.admin',
@@ -74,7 +75,7 @@ INSTALLED_APPS = (
 CELERYBEAT_SCHEDULE = {
     'sync_face_similar_data_to_redis': {
         'task': 'injection.data_sync.tasks.sync_face_similar_data_to_redis',
-        'schedule': timedelta(seconds=120),
+        'schedule': timedelta(seconds=10),
         'args': ()
     },
 }
@@ -134,7 +135,7 @@ DATABASES = {
         'USER': 'work',
         'PASSWORD': 'Gengmei123',
         # 'HOST': 'rm-2ze5k2we69904787l.mysql.rds.aliyuncs.com',
-        'HOST':'rm-2zeaut61u9sm21m0bjo.mysql.rds.aliyuncs.com',
+        'HOST': 'rm-2zeaut61u9sm21m0bjo.mysql.rds.aliyuncs.com',
         'PORT': '3306',
         'OPTIONS': {
             "init_command": "SET foreign_key_checks = 0;",