From 0cec9f5e2691c760f67f7d7c49daa1bf821b63ab Mon Sep 17 00:00:00 2001 From: hcl00521 Date: Mon, 22 Sep 2025 16:22:05 +0800 Subject: [PATCH 1/3] Update export_odps_sink_demo.py MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 修改demo中类型处理 --- tests/export_examples/export_odps_sink_demo.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/tests/export_examples/export_odps_sink_demo.py b/tests/export_examples/export_odps_sink_demo.py index f9ff7673..c7a1b7c2 100644 --- a/tests/export_examples/export_odps_sink_demo.py +++ b/tests/export_examples/export_odps_sink_demo.py @@ -45,8 +45,7 @@ def update_export(): jobName = '11111' config = getJobConfig(client, project, jobName) # 获取任务的配置 config['displayName'] = config['displayName'] + 'new' - config['configuration']['sink']['delaySeconds'] = 909 - export = json.dumps(config) + client.update_export(project_name=project, job_name=jobName, export=export) From 8ccab36f321ffa387241f80cc51c37d5e07e7e3f Mon Sep 17 00:00:00 2001 From: hcl00521 Date: Mon, 22 Sep 2025 16:26:41 +0800 Subject: [PATCH 2/3] Update logclient.py MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 优化update_export接口 export参数类型 --- aliyun/log/logclient.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/aliyun/log/logclient.py b/aliyun/log/logclient.py index cc426ccf..5cd73679 100644 --- a/aliyun/log/logclient.py +++ b/aliyun/log/logclient.py @@ -5516,13 +5516,11 @@ def update_export(self, project_name, job_name, export): :type job_name: string :param job_name: the job name of export job - :type export: string + :type export: Export :param export: the export job configuration """ - if not isinstance(export, str): - raise TypeError("export type must be string") params = {"action": "RESTART"} - body = six.b(export) + body = six.b(json.dumps(export)) headers = {'Content-Type': 'application/json', 'x-log-bodyrawsize': str(len(body))} resource = "/jobs/" + job_name (resp, header) = self._send("PUT", project_name, body, resource, params, headers) @@ -6384,3 +6382,4 @@ def delete_store_view(self, project_name, store_view_name): resource = "/storeviews/" + store_view_name (resp, header) = self._send("DELETE", project_name, None, resource, params, {}) return DeleteStoreViewResponse(header, resp) + From 39df21481c1e1678d46700b65b757a4c54888669 Mon Sep 17 00:00:00 2001 From: hcl00521 Date: Mon, 22 Sep 2025 16:32:26 +0800 Subject: [PATCH 3/3] Update export_odps_sink_demo.py MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 优化参数类型 --- tests/export_examples/export_odps_sink_demo.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/export_examples/export_odps_sink_demo.py b/tests/export_examples/export_odps_sink_demo.py index c7a1b7c2..fb16e7a0 100644 --- a/tests/export_examples/export_odps_sink_demo.py +++ b/tests/export_examples/export_odps_sink_demo.py @@ -43,8 +43,8 @@ def update_export(): client = LogClient("region", "ak", "ak_key") project = '11111' jobName = '11111' - config = getJobConfig(client, project, jobName) # 获取任务的配置 - config['displayName'] = config['displayName'] + 'new' + export = getJobConfig(client, project, jobName) # 获取任务的配置 + export['displayName'] = export['displayName'] + 'new' client.update_export(project_name=project, job_name=jobName, export=export)