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) + diff --git a/tests/export_examples/export_odps_sink_demo.py b/tests/export_examples/export_odps_sink_demo.py index f9ff7673..fb16e7a0 100644 --- a/tests/export_examples/export_odps_sink_demo.py +++ b/tests/export_examples/export_odps_sink_demo.py @@ -43,10 +43,9 @@ def update_export(): client = LogClient("region", "ak", "ak_key") project = '11111' jobName = '11111' - config = getJobConfig(client, project, jobName) # 获取任务的配置 - config['displayName'] = config['displayName'] + 'new' - config['configuration']['sink']['delaySeconds'] = 909 - export = json.dumps(config) + export = getJobConfig(client, project, jobName) # 获取任务的配置 + export['displayName'] = export['displayName'] + 'new' + client.update_export(project_name=project, job_name=jobName, export=export)