|
|
@@ -11,7 +11,7 @@ class Record(object):
|
|
|
"""
|
|
|
|
|
|
def __init__(self, params, mysql_client, config):
|
|
|
- self.content_trace_id = None
|
|
|
+ self.video_pool_trace_id = None
|
|
|
self.flow_pool_level = None
|
|
|
self.content_id = None
|
|
|
self.account_name = None
|
|
|
@@ -40,7 +40,7 @@ class Record(object):
|
|
|
self.flow_pool_level = self.params['flowPoolLevelTag']
|
|
|
self.publish_flag = self.params.get('publishFlag', 1)
|
|
|
self.channel_content_id = self.params.get("channelContentId")
|
|
|
- self.content_trace_id = self.params.get("contentTraceId")
|
|
|
+ self.video_pool_trace_id = self.params.get("videoPoolTraceId")
|
|
|
logging(
|
|
|
code="1001",
|
|
|
info="搜索视频内容接口请求成功, 参数校验成功",
|
|
|
@@ -73,7 +73,7 @@ class Record(object):
|
|
|
request_time = int(time.time())
|
|
|
insert_sql = f"""
|
|
|
INSERT INTO {self.article_match_video_table}
|
|
|
- (trace_id, content_id, flow_pool_level, gh_id, account_name, request_timestamp, publish_flag, content_trace_id)
|
|
|
+ (trace_id, content_id, flow_pool_level, gh_id, account_name, request_timestamp, publish_flag, video_pool_trace_id)
|
|
|
VALUES
|
|
|
(%s, %s, %s, %s, %s, %s, %s, %s);
|
|
|
"""
|
|
|
@@ -87,7 +87,7 @@ class Record(object):
|
|
|
self.account_name,
|
|
|
request_time,
|
|
|
self.publish_flag,
|
|
|
- self.content_trace_id
|
|
|
+ self.video_pool_trace_id
|
|
|
)
|
|
|
)
|
|
|
logging(
|
luojunhui