diff --git a/hik_push/__pycache__/read_event.cpython-312.pyc b/hik_push/__pycache__/read_event.cpython-312.pyc index 963ceac..a362dc1 100644 Binary files a/hik_push/__pycache__/read_event.cpython-312.pyc and b/hik_push/__pycache__/read_event.cpython-312.pyc differ diff --git a/hik_push/main.py b/hik_push/main.py index 8ad020a..dd826e4 100644 --- a/hik_push/main.py +++ b/hik_push/main.py @@ -8,7 +8,7 @@ app = FastAPI() async def add_stream(data: dict): - redis = await aioredis.Redis(host="127.0.0.1", port=6379) + redis = await aioredis.Redis(host="127.0.0.1", port=7019, password="SMHdFrlK") await redis.lpush("hik-sub-event", json.dumps(data)) await redis.close() diff --git a/hik_push/mapping/__pycache__/event_map.cpython-312.pyc b/hik_push/mapping/__pycache__/event_map.cpython-312.pyc new file mode 100644 index 0000000..8bd3a38 Binary files /dev/null and b/hik_push/mapping/__pycache__/event_map.cpython-312.pyc differ diff --git a/hik_push/read_event.py b/hik_push/read_event.py index 0c92705..f53e7d4 100644 --- a/hik_push/read_event.py +++ b/hik_push/read_event.py @@ -22,7 +22,7 @@ async def read_event(): print(config) user_map = config['user_ids'] device_map = config['devices'] - redis_client = await aioredis.Redis(host="127.0.0.1", port=6379) + redis_client = await aioredis.Redis(host="127.0.0.1", port=7019, password="SMHdFrlK") while True: data = await redis_client.brpop("hik-sub-event") sub_json = json.loads(data[1].decode('utf-8'))