|
@@ -277,18 +277,18 @@ async def video_sender(video_obj, user, trace_id, platform, content_id):
|
|
|
header = {
|
|
|
"Content-Type": "application/json",
|
|
|
}
|
|
|
- # response = await request_etl(
|
|
|
- # url="http://192.168.203.137:4612/etl",
|
|
|
- # headers=header,
|
|
|
- # json_data=mq_obj
|
|
|
- # )
|
|
|
- # return response
|
|
|
response = await request_etl(
|
|
|
- url="http://localhost:4612/etl",
|
|
|
+ url="http://192.168.203.137:4612/etl",
|
|
|
headers=header,
|
|
|
json_data=mq_obj
|
|
|
)
|
|
|
return response
|
|
|
+ # response = await request_etl(
|
|
|
+ # url="http://localhost:4612/etl",
|
|
|
+ # headers=header,
|
|
|
+ # json_data=mq_obj
|
|
|
+ # )
|
|
|
+ # return response
|
|
|
|
|
|
|
|
|
async def search_videos(params, trace_id, gh_id, mysql_client):
|