q792602257/FrameTour-RenderWorker
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加开始接口

Browse Source
This commit is contained in:
Jerry Yan 2024-12-13 12:15:15 +08:00
parent 515bf156ab
commit 5ed7198a8a
2 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
biz/task.py
View File

@ -10,6 +10,7 @@ def normalize_task(task_info):
def start_task(task_info): def start_task(task_info):
from biz.ffmpeg import parse_ffmpeg_task, start_ffmpeg_task, clear_task_tmp_file from biz.ffmpeg import parse_ffmpeg_task, start_ffmpeg_task, clear_task_tmp_file
task_info = normalize_task(task_info) task_info = normalize_task(task_info)
api.report_task_start(task_info)
template_info = get_template_def(task_info.get("templateId")) template_info = get_template_def(task_info.get("templateId"))
ffmpeg_task = parse_ffmpeg_task(task_info, template_info) ffmpeg_task = parse_ffmpeg_task(task_info, template_info)
result = start_ffmpeg_task(ffmpeg_task) result = start_ffmpeg_task(ffmpeg_task)

10
util/api.py
View File

@ -107,6 +107,16 @@ def report_task_success(task_info):
return None return None
def report_task_start(task_info):
try:
response = session.post('{0}/{1}/start'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={
'accessKey': os.getenv('ACCESS_KEY'),
}, timeout=10)
except requests.RequestException as e:
logger.error("请求失败！", e)
return None
def report_task_failed(task_info): def report_task_failed(task_info):
try: try:
response = session.post('{0}/{1}/fail'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={ response = session.post('{0}/{1}/fail'.format(os.getenv('API_ENDPOINT'), task_info.get("id")), json={