|
@@ -57,11 +57,12 @@ async def save_video_to_mysql(video_obj, user, trace_id, platform, content_id, c
|
|
|
mq_obj = {}
|
|
mq_obj = {}
|
|
|
mq_obj['trace_id'] = trace_id
|
|
mq_obj['trace_id'] = trace_id
|
|
|
mq_obj['content_id'] = content_id
|
|
mq_obj['content_id'] = content_id
|
|
|
|
|
+ out_video_id = mq_obj['video_id']
|
|
|
# 先查询此content_id下是否有out_video_id了
|
|
# 先查询此content_id下是否有out_video_id了
|
|
|
select_sql = f"""
|
|
select_sql = f"""
|
|
|
SELECT id
|
|
SELECT id
|
|
|
FROM {crawler_video_table}
|
|
FROM {crawler_video_table}
|
|
|
- WHERE out_video_id = '{mq_obj['video_id']}' and content_id = '{content_id}';
|
|
|
|
|
|
|
+ WHERE out_video_id = '{out_video_id}' and content_id = '{content_id}';
|
|
|
"""
|
|
"""
|
|
|
result = await db_client.async_select(select_sql)
|
|
result = await db_client.async_select(select_sql)
|
|
|
if result:
|
|
if result:
|
