@@ -3,10 +3,8 @@
"""
import os
-import time
import oss2
-import json
import aiohttp
import aiofiles
from hashlib import md5
@@ -211,5 +209,4 @@ class AsyncETL(object):
video_path=oss_video,
cover=oss_cover
)
- print(json.dumps(result, ensure_ascii=False, indent=4))
return result["data"]["id"]
@@ -293,7 +293,6 @@ async def search_videos(params, trace_id, gh_id, mysql_client):
WHERE
trace_id = '{trace_id}'
- print(update_id_sql)
await mysql_client.async_insert(update_id_sql)
else:
logging(code="7003", info="视频搜索失败", trace_id=trace_id)
@@ -3,13 +3,14 @@
from applications.search import *
-keys = "拜登政策"
+keys = "库里"
-wx_result = wx_search(keys)
+sensitive = ["习近平"]
+wx_result = wx_search(keys, sensitive)
print(wx_result)
-xg_result = xigua_search(keys)
+xg_result = xigua_search(keys, sensitive)
print(xg_result)
-baidu_result = hksp_search(keys)
-print(baidu_result)
+baidu_result = hksp_search(keys, sensitive)
+print(baidu_result)