更新定时SQL任务

def update_scheduled_sql(self, project_name, scheduled_sql):

import os
import time
from aliyun.log import LogClient
from aliyun.log.scheduled_sql import *

accessKeyId = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')  # The AccessKeyId
accessKeySecret = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')  # The AccessKeySecret

endpoint = "cn-hangzhou.log.aliyuncs.com"  # The  source endpoint of the project's region
roleArn = "acs:ram::141******5616316:role/aliyunserviceroleforslsaudit"  # The roleArn
project = "demo-test-project"  # The source project name
source_logstore = "test-logstore"  # The source logstore name
source_metricstore = ""  # The source metricstore name

dest_endpoint = "cn-hangzhou.log.aliyuncs.com"  # The endpoint of the destination project's region
dest_role_arn = "acs:ram::141******5616316:role/aliyunserviceroleforslsaudit"  # The destination roleArn
dest_project = "demo-test-project"  # The destination project name
dest_logstore = "test-logstore2"  # The destination logstore name
dest_metricstore = ""  # The destination metricstore name

from_time = int(time.time()) - 300  # The start time of the scheduled SQL task

job_name = "test-001"  # The job name
display_name = "test-001-update"  # The display name
description = "修改一个定时SQL任务"  # The description

script = "* | select *"  # The SQL script
promql = "* | select promql_query_range('key{}') from metrics limit 1000"  # The PromQL script

instance_id = ""  # The job instanceId for schedule sql
delay_seconds = 0  # the delay seconds for schedule sql

# three possible values for the variable data_format  : "log2log" , "log2metric" ,"metric2metric"
data_format = "log2log"

# Possible values for the variable schedule_type: "FixedRate", "Daily", "Weekly", "Hourly", "Cron"
# schedule_type = "FixedRate"
schedule_type = "FixedRate"

client = LogClient(endpoint, accessKeyId, accessKeySecret)


def update_schedule_sql():
    scheduled_sql_config = get_schedule_sql()

    configuration = scheduled_sql_config['configuration']
    schedule = scheduled_sql_config['schedule']

    configuration['fromTimeExpr'] = '@m-3m'
    configuration['maxRetries'] = 25

    schedule['type'] = 'Cron'
    schedule['timeZone'] = '+0800'
    schedule['interval'] = ''
    schedule['dayOfWeek'] = ''
    schedule['hour'] = ''
    schedule['cronExpression'] = '*/2 * * * *'

    schedule = dict_to_schedule_rule(schedule)
    configuration = dict_to_scheduled_sql_config(configuration)

    schedule_sql = ScheduledSQL()
    schedule_sql.setSchedule(schedule)
    schedule_sql.setConfiguration(configuration)
    schedule_sql.setName(job_name)
    schedule_sql.setDisplayName(display_name)
    schedule_sql.setDescription(description)

    update_schedule_sql_response = client.update_scheduled_sql(dest_project, schedule_sql)
    update_schedule_sql_response.log_print()


def get_schedule_sql():
    get_schedule_sql_response = client.get_scheduled_sql(dest_project, job_name)
    scheduled_sql_config = get_schedule_sql_response.scheduled_sql_config
    return scheduled_sql_config


if __name__ == "__main__":
    update_schedule_sql()
    pass

UpdateScheduledSqlJobResponse:
headers: {'Server': 'AliyunSLS', 'Content-Length': '0', 'Connection': 'keep-alive', 'Access-Control-Allow-Origin': '*', 'Date': 'Fri, 01 Nov 2024 08:18:08 GMT', 'x-log-time': '1730449088', 'x-log-requestid': '67248EC069A98605C79EED79'}

Process finished with exit code 0