From 225b9a01e845e01a50f11628299bc2c9507e7db2 Mon Sep 17 00:00:00 2001 From: zxl Date: Fri, 20 Dec 2024 14:33:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=20--header=20repeatable=3Dye?= =?UTF-8?q?s=20=E5=8F=AF=E4=BF=AE=E6=94=B9=E6=AD=A3=E5=9C=A8=E8=BF=90?= =?UTF-8?q?=E8=A1=8C=E7=9A=84task=E7=8A=B6=E6=80=81=EF=BC=8C=E4=BD=BF?= =?UTF-8?q?=E5=85=B6=E9=87=8D=E6=96=B0=E6=89=A7=E8=A1=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../message-router/messageRoute.py | 17 ++++++++++++++++- 1 file changed, 16 insertions(+), 1 deletion(-) diff --git a/L1/pipelines/csst-msc-l1-mbi/message-router/messageRoute.py b/L1/pipelines/csst-msc-l1-mbi/message-router/messageRoute.py index 5639068..435ebe4 100644 --- a/L1/pipelines/csst-msc-l1-mbi/message-router/messageRoute.py +++ b/L1/pipelines/csst-msc-l1-mbi/message-router/messageRoute.py @@ -99,19 +99,34 @@ class messageRoute(): def sendmsg(self,dag_run_id,job,message): #执行解包操作 print("sendmsg dag_run_id is "+dag_run_id) + messageRoute.append_dagrunid(dag_run_id) message = "'"+message+"'" - command = f"scalebox task add --header dag_run_id={dag_run_id} --upsert --sink-job={job} {message}" + command = f"scalebox task add --header dag_run_id={dag_run_id} --header repeatable=yes --upsert --sink-job={job} {message}" print("command : "+command) result=subprocess.run(command, shell=True) if result.returncode == 0: print(f"send message {message} to {job}") + # dag_run_id记入/work/extra-attributes.txt print("命令执行成功") return result.returncode else: print(f"命令执行失败，返回码为: {result.returncode}") return result.returncode + @classmethod + def append_dagrunid(self,dag_run_id): + file_path='/work/extra-attributes.txt' + content_to_append=f"dag_run_id:{dag_run_id}\n" + # 以追加模式打开文件 + try: + with open(file_path, 'a', encoding='utf-8') as file: + # 追加内容 + file.write(content_to_append) + print(f"追加完成,dag_run_id : {dag_run_id}") + except IOError as e: + print(f"写入文件/work/extra-attributes.txt时发生错误：{e}") + if __name__ == '__main__': parameter = sys.argv message=parameter[1] -- GitLab