no message

jobs/rainfall_conditions_job.py

@@ -4,6 +4,7 @@ from datetime import datetime, timedelta
 from sqlalchemy.orm import Session
 from common.BigDataCenterAPI import *
 from utils import *
+from utils.redis_util import *
 from models import *
 from exceptions import *
 from database import get_db_local
@@ -100,8 +101,12 @@ def put_data(db=get_db_local()):
             db.commit()
 
 def proc():
-    logger.info(datetime.now())
-    try:
-        put_data()
-    except:
-        pass
+    lock_key = "rainfall_conditions_job"
+    if redis_lock(lock_key):
+        logger.info(datetime.now())
+        try:
+            put_data()
+        except:
+            pass
+        finally:
+            redis_unlock(lock_key)

jobs/yzy_job.py

@@ -11,6 +11,7 @@ from extensions import logger
 from common import YzyApi
 from config import settings
 import traceback
+import inspect
 
 def proc():
     lock_key = "yzy_job_proc"
@@ -45,7 +46,7 @@ def proc():
         redis_unlock(lock_key)
 
 def yzy_msg_queue_proc():
-    lock_key = "yzy_job_proc"
+    lock_key = "yzy_msg_queue_job"
     if redis_lock(lock_key):
         logger.info(datetime.now())
         db = get_db_local()