update

workers/consumption_work.py

@@ -435,8 +435,8 @@ class ConsumptionRecommend(object):
     @classmethod
     def run(cls):
         logger.info(f"[处理] 开始获取redis数据")
-        # fs_data = os.getenv("FS_DATA")
-        fs_data = '邓锋,DEpi6V,task:carry_data_redis_df'
+        fs_data = os.getenv("FS_DATA")
+        # fs_data = '邓锋,DEpi6V,task:carry_data_redis_df'
         fs_data_list = fs_data.split(',')
         redis_name = fs_data_list[2]
         data = RedisHelper().get_client().rpop(name = redis_name)