记录请求

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

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 = {