调试

common/redis.py

@@ -15,8 +15,8 @@ class SyncRedisHelper:
     def _get_pool(self) -> redis.ConnectionPool:
         if self._pool is None:
             self._pool = redis.ConnectionPool(
-                # host="r-bp1mb0v08fqi4hjffupd.redis.rds.aliyuncs.com",  # 外网地址
-                host="r-bp1mb0v08fqi4hjffu.redis.rds.aliyuncs.com",  # 内网地址
+                host="r-bp1mb0v08fqi4hjffupd.redis.rds.aliyuncs.com",  # 外网地址
+                # host="r-bp1mb0v08fqi4hjffu.redis.rds.aliyuncs.com",  # 内网地址
                 port=6379,
                 db=0,
                 password="Wqsd@2019",
@@ -34,7 +34,6 @@ class SyncRedisHelper:
         if self._pool:
             self._pool.disconnect(inuse_connections=True)
 
-
 def insert_carry_data(dt, REDIS_NAME,FS_SHEET, NAME):
     data = Material.get_carry_data(dt, FS_SHEET,NAME)
     if not data:
@@ -44,7 +43,6 @@ def insert_carry_data(dt, REDIS_NAME,FS_SHEET, NAME):
     client.rpush(REDIS_NAME, *data)
     return len(data)
 
-
 def get_carry_data(REDIS_NAME):
     """获取一条需要打标签的视频"""
     helper = SyncRedisHelper()

docker-compose.yml

@@ -110,6 +110,8 @@ services:
       - TASK_TYPE=redis
       - NAME=范军
       - REDIS_NAME=task:carry_data_redis_fj
+#    volumes:
+#      - "./carry_data_handle.py:/app/carry_data_handle.py"
     networks:
       - carry_net
     entrypoint: "python /app/carry_data_handle.py"