Simple Log Service:Update a scheduled SQL job

Prerequisites

Parameters

def update_scheduled_sql(self, project_name, scheduled_sql):

Request parameters

scheduled_sql parameter

schedule parameter

Configuration parameter

{
 addLabels: "{}",
 hashLabels: "[]",
 labelKeys: "[\"your label1\",\"your label2\"]",
 metricKeys: "[\"your Indicator1\",\"your Indicator2\"]",
 metricName: "",
 timeKey: ""
}

Response parameters

See UpdateScheduledSQL.

Sample code

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 AccessKey ID.
accessKeySecret = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')  # The AccessKey secret.

endpoint = "cn-hangzhou.log.aliyuncs.com"  # The endpoint of the project's region.
roleArn = "acs:ram::141******5616316:role/aliyunserviceroleforslsaudit"  # The role ARN.
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 role ARN.
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 job.

job_name = "test-001"  # The job name.
display_name = "test-001-update"  # The display name.
description = "Modify a scheduled SQL job"  # The description.

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

instance_id = ""  # The instance ID of the scheduled SQL job.
delay_seconds = 0  # The delay for the scheduled SQL job in seconds.

# Three possible values for the data_format variable: "log2log", "log2metric", and "metric2metric".
data_format = "log2log"

# Possible values for the schedule_type variable: "FixedRate", "Daily", "Weekly", "Hourly", and "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

Sample response

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

References

• For more information about the API operations used to manage scheduled SQL jobs, see the following topics:

  • CreateScheduledSQL

  • DeleteScheduledSQL

  • UpdateScheduledSQL

  • EnableScheduledSQL

  • DisableScheduledSQL

  • ListScheduledSQLs

  • GetScheduledSQL

• For more sample code, see Alibaba Cloud Simple Log Service SDK for Python on GitHub.