|
|
@@ -17,6 +17,9 @@ def get_data_task():
|
|
|
top_tasks = [] # 使用集合去重
|
|
|
for i in range(100):
|
|
|
top_task = get_top_data("task:top_all_data")
|
|
|
+ logger.info(f"[+] 获取第{i}个")
|
|
|
+ current_time = datetime.now()
|
|
|
+ formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
|
|
|
if top_task:
|
|
|
time.sleep(1)
|
|
|
data = json.loads(top_task)
|
|
|
@@ -27,8 +30,7 @@ def get_data_task():
|
|
|
else:
|
|
|
AliyunLogger.logging("空", data, "不处理","fail")
|
|
|
|
|
|
- current_time = datetime.now()
|
|
|
- formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
|
|
|
+
|
|
|
values = [
|
|
|
[
|
|
|
data['uid'],
|
|
|
@@ -52,9 +54,30 @@ def get_data_task():
|
|
|
logger.info(f"[+] 改内容为:{channel_id},不做处理")
|
|
|
continue
|
|
|
else:
|
|
|
+ top_tasks.append(top_task)
|
|
|
AliyunLogger.logging(channel_id, data, "等待处理", "success")
|
|
|
+ values = [
|
|
|
+ [
|
|
|
+ data['uid'],
|
|
|
+ data['videoid'],
|
|
|
+ data['return_uv'],
|
|
|
+ data['type'],
|
|
|
+ data['type_owner'],
|
|
|
+ data['channel'],
|
|
|
+ data['channel_owner'],
|
|
|
+ data['title'],
|
|
|
+ data['dt'],
|
|
|
+ "",
|
|
|
+ "",
|
|
|
+ formatted_time
|
|
|
+ ]
|
|
|
+ ]
|
|
|
+ Feishu.insert_columns("KUIksoqZkhvZOrtqA1McPwObn7d", "57c076", "ROWS", 1, 2)
|
|
|
+ time.sleep(0.5)
|
|
|
+ Feishu.update_values("KUIksoqZkhvZOrtqA1McPwObn7d", "57c076", "A2:Z2", values)
|
|
|
+ logger.info(f"[+] 成功写入飞书表格")
|
|
|
+ logger.info(f"[+] 改内容为:{channel_id},不做处理")
|
|
|
|
|
|
- top_tasks.append(top_task)
|
|
|
return top_tasks
|
|
|
|
|
|
def video_task_start():
|
