获取定时SQL任务

def get_scheduled_sql(self, project_name, job_name):

import os
from aliyun.log import LogClient


def main():
    # 本示例从环境变量中获取AccessKey ID和AccessKey Secret
    accessKeyId = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_ID', '')
    accessKey = os.environ.get('ALIBABA_CLOUD_ACCESS_KEY_SECRET', '')

    # 日志服务的服务接入点
    endpoint = "cn-hangzhou.log.aliyuncs.com"
    project_name = "demo-test-project"
    job_name = "test-001"

    client = LogClient(endpoint, accessKeyId, accessKey, "")

    res = client.get_scheduled_sql(project_name, job_name)
    res.log_print()


if __name__ == '__main__':
    main()

GetScheduledSqlResponse:
headers: {'Server': 'AliyunSLS', 'Content-Type': 'application/json', 'Content-Length': '971', 'Connection': 'keep-alive', 'Access-Control-Allow-Origin': '*', 'Date': 'Fri, 01 Nov 2024 07:11:52 GMT', 'x-log-time': '1730445112', 'x-log-requestid': '67247F3880283CB6EAA247C6'}
scheduled_sql:  {'name': 'test-001', 'type': 'ScheduledSQL', 'apiType': 'ScheduledSQL', 'status': 'ENABLED', 'description': '创建一个定时SQL任务', 'displayName': 'test-001', 'state': 'Enabled', 'recyclable': False, 'schedule': {'type': 'FixedRate', 'delay': 0, 'interval': '60s', 'runImmediately': False, 'timeZone': '+0800'}, 'configuration': {'roleArn': 'acs:ram::141******5616316:role/aliyunserviceroleforslsaudit', 'destRoleArn': 'acs:ram::141******5616316:role/aliyunserviceroleforslsaudit', 'sourceLogstore': 'test-logstore', 'destEndpoint': 'cn-hangzhou.log.aliyuncs.com', 'destProject': 'demo-test-project', 'destLogstore': 'test-logstore2', 'fromTimeExpr': '@m - 5m', 'toTimeExpr': '@m', 'maxRunTimeInSeconds': 1800, 'maxRetries': 10, 'forceComplete': False, 'fromTime': 1730444541, 'toTime': 0, 'sqlType': 'searchQuery', 'resourcePool': 'enhanced', 'dataFormat': 'log2log', 'version': 0, 'script': '* | select *', 'parameters': {}}, 'scheduleId': 'f3bc8ba5ccb******c68f34ea8fdcf8d', 'createTime': 1730444990, 'lastModifiedTime': 1730444990}

Process finished with exit code 0