获取OSS导入任务

更新时间:2025-01-20 06:32:18

调用GetOSSIngestion接口获取OSS导入任务。

前提条件

  • 开通日志服务

  • 已安装Python、Python开发环境(例如PyCharm)和Python的包管理工具pip

    • 日志服务Python SDK新版支持Python3.7及以上版本。

    • 您可以执行python -V命令检查已安装的Python版本。

    • 您可以执行pip3 -V命令检查您已安装的pip版本。

  • 已安装日志服务Python SDK新版。

    • 在命令行工具中,执行如下命令完成安装。

      pip install alibabacloud_sls20201230
    • 安装SDK新版后,执行如下命令进行验证。

      pip show alibabacloud_sls20201230
  • 已配置环境变量ALIBABA_CLOUD_ACCESS_KEY_IDALIBABA_CLOUD_ACCESS_KEY_SECRET。具体操作,请参见Linux、macOSWindows系统中配置环境变量

参数说明

def get_ossingestion(
        self,
        project: str,
        oss_ingestion_name: str,
) -> sls_20201230_models.GetOSSIngestionResponse:

请求参数

名称

类型

是否必填

描述

示例值

名称

类型

是否必填

描述

示例值

project

String

Project名称。

ali-test-project

oss_ingestion_name

String

OSS导入任务名称。

ingest-oss-123456

返回参数

返回参数说明,请参见GetOSSIngestion - 获取OSS导入任务

示例代码

import os

from alibabacloud_sls20201230.client import Client as Sls20201230Client
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_sls20201230 import models as sls_20201230_models
from alibabacloud_tea_util.client import Client as UtilClient


def main():
    config = open_api_models.Config(
        # 必填,请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。,
        access_key_id=os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
        # 必填,请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。,
        access_key_secret=os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
    )
    # 日志服务的服务接入点
    config.endpoint = "cn-hangzhou.log.aliyuncs.com"
    project_name = "ali-test-project"
    oss_ingestion_name = "ingest-oss-123456"
    client = Sls20201230Client(config)
    try:
        response = client.get_ossingestion(project_name, oss_ingestion_name)
        print(response)
    except Exception as error:
        print(error.message)
        print(error.data.get("Recommend"))
        UtilClient.assert_as_string(error.message)


if __name__ == '__main__':
    main()

示例返回结果

{'headers': {'server': 'AliyunSLS', 'content-type': 'application/json', 'content-length': '603', 'connection': 'keep-alive', 'access-control-allow-origin': '*', 'date': 'Thu, 31 Oct 2024 08:46:59 GMT', 'x-log-time': '1730364419', 'x-log-requestid': '672344030326D19FD1F73E56'}, 'statusCode': 200, 'body': {'configuration': {'logstore': 'test-logstore', 'source': {'bucket': 'oss-test-shanghai001', 'compressionCodec': 'none', 'encoding': 'UTF-8', 'endpoint': 'cn-shanghai-internal.aliyuncs.com', 'format': {'type': 'Line'}, 'interval': '30s', 'useMetaIndex': False}}, 'createTime': 1730359624, 'description': '这是一个描述test', 'displayName': 'OSS导入测试', 'lastModifiedTime': 1730359624, 'name': 'ingest-oss-123456', 'schedule': {'type': 'Resident'}, 'scheduleId': 'e64359bc5328******bfb8e935ebca09', 'status': 'RUNNING'}}

Process finished with exit code 0

相关文档

  • 本页导读 (1)
  • 前提条件
  • 参数说明
  • 请求参数
  • 返回参数
  • 示例代码
  • 示例返回结果
  • 相关文档