判断等级

moment/views/process_time.py

@@ -332,7 +332,7 @@ def judge_offset_partition_have_consum(offset=0, partition=0):
         key = "irrigation_partition_offset_have_consum:" + str(partition)
         redis_data = redis_client.get(key)
         if redis_data:
-            redis_list_data = set(json.loads(redis_data))
+            redis_list_data = set(json.loads(str(redis_data, encoding="utf8")))
             if offset in redis_list_data:
                 return False
         redis_list_data.add(offset)