diff --git a/routers/point.py b/routers/point.py index b18b073..8682fb0 100644 --- a/routers/point.py +++ b/routers/point.py @@ -20,7 +20,9 @@ def dest_partition(s: str) -> int: @router.post("/") async def point(request: Request, items: DataModel): try: - print(items.json()) + if items.public.get('b01') != 'e903ab24ad8f4bfca8a3ce7e122cd102': + print(items.json()) + public_data, _ = restore_field(items.public) rdb = request.app.state.redis data_factory = request.app.state.data_factory diff --git a/settings.py b/settings.py index c20b564..2bb3b62 100644 --- a/settings.py +++ b/settings.py @@ -65,13 +65,14 @@ class Config: '3F9AdWKZGhhNS2': 's4epprEG8DdyG5', 'G5OYZLM21H': 's4epprEG8DdyG5', 'c3e0409ac18341149877b08f087db640': 's4epprEG8DdyG5', - 'e903ab24ad8f4bfca8a3ce7e122cd102': 'asfsdafasdsf' + 'e903ab24ad8f4bfca8a3ce7e122cd102': 'asfsdafasdsf', + 'qXIPFypDlLqCuHdQ': 'asfsdafasdsf', # 山海 } # 映射数数 appID APPID_MAP = { '3F9AdWKZGhhNS2': 'a77703e24e6643d08b74a4163a14f74c', - 'e903ab24ad8f4bfca8a3ce7e122cd102':'e903ab24ad8f4bfca8a3ce7e122cd102' + 'e903ab24ad8f4bfca8a3ce7e122cd102': 'e903ab24ad8f4bfca8a3ce7e122cd102' } # appid 发送到对应 topic @@ -79,7 +80,8 @@ class Config: '3F9AdWKZGhhNS2': 'test', 'G5OYZLM21H': 'test', 'c3e0409ac18341149877b08f087db640': 'test2', - 'e903ab24ad8f4bfca8a3ce7e122cd102': 'zhengba_test' + 'e903ab24ad8f4bfca8a3ce7e122cd102': 'zhengba_test', + 'qXIPFypDlLqCuHdQ': 'shanhai' } KAFKA_CONF = {