数据接入相关 API

连接器

创建连接器

POST /connectors

输入参数：

参数	是否必填	含义
name	是	连接器名称
source_type	是	连接器类型，1: DIFY, 2: HDFS, 3: MO, 4: OSS, 5: S3
oss	否	OSS 连接配置（当 source_type=4 时必填）
s3	否	S3 连接配置（当 source_type=5 时必填）
dify	否	DIFY 连接配置（当 source_type=1 时必填）
hdfs	否	HDFS 连接配置（当 source_type=2 时必填）
mo	否	MO 连接配置（当 source_type=3 时必填）
usage_type	否	使用类型数组

body：

{
    "name": "new_connector_name",
    "source_type": 4,
    "oss": { // 如果source_type为4，填此字段
        "endpoint": "example_oss_endpoint",
        "access_key_id": "example_access_key_id",
        "access_key_secret": "example_access_key_secret",
        "bucket_name": "example_bucket_name"
    },
    "s3": { // 如果source_type为5，填此字段
        "endpoint": "example_s3_endpoint",
        "access_key_id": "example_access_key_id",
        "access_key_secret": "example_access_key_secret",
        "bucket_name": "example_bucket_name",
        "region": "example_region",
        "path_style": true //路径风格，true为path style，false为virtual hosted style
    },
    "dify": { // 如果source_type为1，填此字段
        "api_key": "example_api_key",
        "api_url": "example_api_url"
    },
    "hdfs": { // 如果source_type为2，填此字段
        "address": "172.21.107.12:8020",
        "auth_type": 1, // 认证方式
        "username": "example_username",
        "file_path": "example_file_path"
    },
    "mo": { // 如果source_type为3，填此字段
        "host": "example_host",
        "port": 6001,
        "username": "example_username",
        "password": "example_password"
    }
}

示例：

import requests

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors"
headers = {
    "moi-key": "xxxxx"
}

body = {
    "name": "oss-test2",  
    "source_type": 4, 
    "oss": {  
        "endpoint": "xxxx",
        "access_key_id": "xxxx",
        "access_key_secret": "xxxx",
        "bucket_name": "xxxx"
    }
}

response = requests.post(url, json=body, headers=headers)

if response.status_code == 200:
    print(response.json()) 
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

返回：

{'code': 'OK', 'msg': 'OK'}

验证连接器

POST /connectors/validate

输入参数：

参数	是否必填	含义
source_type	是	连接器类型，1: DIFY, 2: HDFS, 3: MO, 4: OSS, 5: S3
connector_id	否	填写 connector_id 则无需填写配置信息
oss	否	OSS 连接配置（当 source_type=4 时必填）
s3	否	S3 连接配置（当 source_type=5 时必填）
dify	否	DIFY 连接配置（当 source_type=1 时必填）
hdfs	否	HDFS 连接配置（当 source_type=2 时必填）
mo	否	MO 连接配置（当 source_type=3 时必填）

示例：

import requests

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors/validate"  
headers = {
    "moi-key": "xxxxx"
}

body = {
    "source_type": 4,
    "oss": {
        "endpoint": "xxxx",
        "access_key_id": "xxxx",
        "access_key_secret": "xxxx",
        "bucket_name": "xxxx"
    }
}

response = requests.post(url, json=body, headers=headers)

if response.status_code == 200:
    print(response.json())  
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

返回示例：

{'code': 'OK', 'msg': 'OK', 'data': {'valid': True}}

查询连接器

GET /connectors/list

输入参数：

参数	数据类型	是否必填	含义	默认值
is_desc	boolean	否	排序顺序	false
keyword	string	否	搜索的关键字（值为空时展示所有连接器）
order_by	string	否	排序的字段
page	int	否	当前页码	1
page_size	int	否	每页显示的数量	10
source_type	int	否	连接器类型筛选
source_type_list	array	否	连接器类型列表筛选
status	string	否	连接状态筛选
status_list	array	否	连接状态列表筛选
usage_type	array	否	使用类型筛选

输出参数：

参数	含义
id	connector-id
source_type	连接器类型，4 为 OSS，5 为标准 S3
name	连接器名称
status	连接状态
created_at	创建时间
updated_at	更新时间
username	创建人
updated_at	更新时间
username	创建人
related_task_ids	关联的 TaskID
usage_type	使用类型数组
oss	OSS 连接配置信息
s3	S3 连接配置信息
dify	DIFY 连接配置信息
hdfs	HDFS 连接配置信息
mo	MO 连接配置信息
total	返回数目

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors/list" 
headers = {
    "moi-key": "xxxxx"
}
params = {
    "is_desc": False,
    "keyword": "c1",
    "order_by": "",
    "page": 1,
    "page_size": 10
}

response = requests.get(url, headers=headers, params=params)

print("Response Body:", json.dumps(response.json(), indent=4, ensure_ascii=False))

返回：

Response Body: {
    "code": "OK",
    "msg": "OK",
    "data": {
        "connectors": [
            {
                "id": 100004,
                "source_type": 4,
                "name": "oss-test1",
                "status": "active",
                "created_at": 1738919558,
                "updated_at": 1738919558,
                "username": "admin",
                "related_task_ids": [
                    1889223922712281088
                ],
                "usage_type": [],
                "oss": {
                    "endpoint": "oss-cn-hangzhou.aliyuncs.com",
                    "access_key_id": "admin",
                    "access_key_secret": "Admin123",
                    "bucket_name": "moc-test-data"
                }
            }
        ],
        "total": 1
    }
}

更新连接器

PUT /connectors/{id}

输入参数：

参数	是否必填	含义
name	否	连接器名称
oss	否	OSS 连接配置（当连接器为 OSS 类型时填写）
s3	否	S3 连接配置（当连接器为 S3 类型时填写）
dify	否	DIFY 连接配置（当连接器为 DIFY 类型时填写）
hdfs	否	HDFS 连接配置（当连接器为 HDFS 类型时填写）
mo	否	MO 连接配置（当连接器为 MO 类型时填写）
usage_type	否	使用类型数组

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors/100005"

headers = {
    "moi-key": "xxxxx"
}

body = {
    "name": "s3-test1",  
    "s3": {
        "endpoint": "xxxx",
        "access_key_id": "xxxx",
        "access_key_secret": "xxxx",
        "bucket_name": "xxxx",
        "region": "xxxx"
    }
}

response = requests.put(url, json=body, headers=headers)

if response.status_code == 200:
    print(response.json()) 
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

删除连接器

DELETE /connectors/{id}

路径参数：

参数	是否必填	含义
id	是	连接器 ID

示例：

import requests

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors/100004"
headers = {
    "moi-key": "xxxxx"
}

response = requests.delete(url, headers=headers)

if response.status_code == 200:
    print(response.json()) 
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

返回：

{'code': 'OK', 'msg': 'OK'}

查询连接器源文件

GET /connectors/files/list

输入参数：

参数	是否必填	含义
connector_id	是	连接器 id
file_types	否	文件类型，0：空文件类型（可能作为默认或无效值）；1：TXT 文本文件类型；2：PDF 文档文件类型 3：图片文件类型；4：PPT 演示文稿文件类型；5：Word 文档文件类型；6：Markdown 标记语言文件类型；7：CSV 逗号分隔值文件类型；8：Parquet 列式存储文件类型；9：SQL 文件类型；10：目录类型

输出参数：

参数	含义
uri	表示源连接器中的唯一资源定位符。
filename	文件名称
size	文件大小
type	文件类型，支持： NIL = 0 TXT = 1 PDF = 2 IMAGE = 3 PPT = 4 WORD = 5 MARKDOWN = 6 CSV = 7 PARQUET = 8 SQL_FILES = 9 DIR = 10 DOCX = 11 PPTX = 12 WAV = 13 MP3 = 14 AAC = 15 FLAC = 16 MP4 = 17 MOV = 18 MKV = 19 PNG = 20 JPG = 21 JPEG = 22 BMP = 23

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors/files/list"

headers = {
    "moi-key": "xxxxx"
}

params = {
    "connector_id": 100004,
    "file_types": 2
}

response = requests.get(url, headers=headers, params=params)

try:
    response_json = response.json()
    print("Response Body:", json.dumps(response_json, indent=4, ensure_ascii=False))
except json.JSONDecodeError:
    print("Response is not in JSON format:", response.text)

返回：

Response Body: {
    "code": "OK",
    "msg": "OK",
    "data": {
        "files": [
            {
                "uri": "红楼梦(通行本)简体横排.pdf",
                "filename": "红楼梦(通行本)简体横排.pdf",
                "size": 6787457,
                "type": 2
            },
            {
                "uri": "file1",
                "filename": "file1",
                "size": 0,
                "type": 10
            }
        ]
    }
}

上传文件到连接器

POST /connectors/upload

输入参数：

参数	是否必填	含义
data	是	多文件数据和请求参数

示例：

import requests

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors/upload"
headers = {
    "moi-key": "xxxxx"
}

files = {'data': open('example.txt', 'rb')}

response = requests.post(url, headers=headers, files=files)

if response.status_code == 200:
    print(response.json()) 
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

获取连接器摘要

GET /connectors/summary

示例：

import requests

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors/summary"
headers = {
    "moi-key": "xxxxx"
}

response = requests.get(url, headers=headers)

if response.status_code == 200:
    print(response.json()) 
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

数据载入

创建载入任务

连接器载入

通过已配置的连接器载入文件到数据卷。

POST /task

输入参数：

参数	是否必填	含义
source_connector_id	是	连接器 id
volume_id	是	要载入的原始卷的的 id
source_config	是	载入任务源配置对象
source_config.common_file_task_config	是	通用文件任务配置对象
source_config.common_file_task_config.load_mode_config	是	载入模式设置对象
source_config.common_file_task_config.load_mode_config.load_interval_type	是	载入周期单位和类型，0：未知的加载间隔类型；1：按天进行加载；2：按小时进行加载；3：按分钟进行加载；4：默认类型，仅加载一次
source_config.common_file_task_config.uris	是	要载入的文件列表
config_type	是	通用文件载入配置类型，默认为 1

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task" 
headers = {
    "moi-key": "xxxxx"
}

body = {
    "source_connector_id":100004,
    "volume_id":"1889578498228068352",
    "source_config":
        {
            "common_file_task_config":
             {
                 "load_mode_config":
                  {
                      "load_interval_type":4
                   },
              "uris":["红楼梦 (通行本) 简体横排.pdf"]
             }
        },
    "config_type":1
}

response = requests.post(url, json=body, headers=headers)
print(response.json())  

返回：

{'code': 'OK', 'msg': 'OK'}

本地上传载入

直接上传本地文件到数据卷，无需预先配置连接器。

POST /connectors/upload

输入参数：

参数	是否必填	含义
file	是	要上传的文件（multipart/form-data 格式）
VolumeID	是	目标数据卷 ID
meta	是	文件元数据（JSON 格式的数组）

meta 参数格式：

参数	是否必填	含义
file_name	是	文件名称
file_size	是	文件大小（字节）
mime_type	否	文件 MIME 类型，默认为 “application/octet-stream”

示例：

import requests
import json
import os
import mimetypes

def upload_file(file_path, volume_id, moi_key):
    """
    上传单个文件到平台
    
    参数：
        file_path (str): 本地文件路径
        volume_id (str): 目标数据卷 ID
        moi_key (str): API 密钥
    """
    
    # 验证文件是否存在
    if not os.path.exists(file_path):
        raise FileNotFoundError(f"文件不存在：{file_path}")
    
    # 构建请求 URL
    url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/connectors/upload"
    
    # 构建请求头
    headers = {
        "Moi-Key": moi_key
    }
    
    # 获取文件信息
    file_name = os.path.basename(file_path)
    file_size = os.path.getsize(file_path)
    mime_type, _ = mimetypes.guess_type(file_path)
    
    # 准备元数据
    meta = json.dumps([{
        "file_name": file_name,
        "file_size": file_size,
        "mime_type": mime_type or "application/octet-stream"
    }])
    
    # 准备文件和表单数据
    with open(file_path, 'rb') as f:
        files = {
            "file": (file_name, f, mime_type or "application/octet-stream")
        }
        
        data = {
            "VolumeID": volume_id,
            "meta": meta
        }
        
        # 发送 POST 请求
        response = requests.post(url, headers=headers, files=files, data=data)
    
    # 检查响应
    response.raise_for_status()
    return response.json()

# 使用示例
file_path = "/path/to/your/file.pdf"
volume_id = "1889578498228068352"
moi_key = "xxxxx"

result = upload_file(file_path, volume_id, moi_key)
print(result)

批量上传示例：

import requests
import json
import os
from pathlib import Path

def batch_upload_files(file_paths, volume_id, moi_key):
    """
    批量上传多个文件
    
    参数：
        file_paths (list): 文件路径列表
        volume_id (str): 目标数据卷 ID
        moi_key (str): API 密钥
    """
    results = []
    
    for file_path in file_paths:
        try:
            result = upload_file(file_path, volume_id, moi_key)
            results.append({
                'file_path': file_path,
                'success': True,
                'result': result
            })
            print(f"✅ 上传成功：{os.path.basename(file_path)}")
        except Exception as e:
            results.append({
                'file_path': file_path,
                'success': False,
                'error': str(e)
            })
            print(f"❌ 上传失败：{os.path.basename(file_path)} - {e}")
    
    return results

# 使用示例
file_paths = [
    "/path/to/file1.pdf",
    "/path/to/file2.txt",
    "/path/to/file3.docx"
]
volume_id = "1889578498228068352"
moi_key = "xxxxx"

results = batch_upload_files(file_paths, volume_id, moi_key)

目录上传示例：

import requests
import json
import os
from pathlib import Path

def upload_directory(directory_path, volume_id, file_extensions=None, recursive=True, moi_key="xxxxx"):
    """
    上传目录中的文件
    
    参数：
        directory_path (str): 目录路径
        volume_id (str): 目标数据卷 ID
        file_extensions (list): 允许的文件扩展名列表，如 ['.txt', '.pdf']
        recursive (bool): 是否递归子目录
        moi_key (str): API 密钥
    """
    
    if not os.path.exists(directory_path):
        raise FileNotFoundError(f"目录不存在：{directory_path}")
    
    # 收集要上传的文件
    file_paths = []
    directory = Path(directory_path)
    
    pattern = "**/*" if recursive else "*"
    
    for file_path in directory.glob(pattern):
        if file_path.is_file():
            # 检查文件扩展名
            if file_extensions:
                if file_path.suffix.lower() in [ext.lower() for ext in file_extensions]:
                    file_paths.append(str(file_path))
            else:
                file_paths.append(str(file_path))
    
    if not file_paths:
        print("❌ 没有找到符合条件的文件")
        return []
    
    print(f"📁 找到 {len(file_paths)} 个文件准备上传")
    
    # 批量上传文件
    return batch_upload_files(file_paths, volume_id, moi_key)

# 使用示例
directory_path = "/path/to/your/directory"
volume_id = "1889578498228068352"
file_extensions = ['.pdf', '.txt', '.docx']  # 只上传这些类型的文件
moi_key = "xxxxx"

results = upload_directory(
    directory_path=directory_path,
    volume_id=volume_id,
    file_extensions=file_extensions,
    recursive=True,
    moi_key=moi_key
)

返回示例：

{
    "code": "OK",
    "msg": "OK", 
    "data": {
        "success": true,
        "file_id": "1889613341347389440",
        "task_id": "1889613340219121664",
        "message": "文件上传成功",
        "results": [
            {
                "success": true,
                "file_id": "1889613341347389440",
                "message": "上传成功"
            }
        ]
    }
}

载入任务列表

GET /task/list

输入参数：

参数	是否必填	含义
is_desc	否	排序
load_interval_types	否	载入间隔，0：未知间隔类型；1：按天；2：按小时；3：按分钟；4：仅执行一次
order_by	否	为载入任务源配置
page	否	页码
page_size	否	当页条数
status	否	表示通用文件载入配置类型，默认为 1

输出参数：

参数	含义
id	载入 id
source_connector_id	连接器 id
source_connector_type	连接器类型
volume_id	原始卷 id
volume_name	原始卷名称
status	载入任务状态，0：未知状态；1：正常执行中或可执行状态；2：正在暂停状态；3：已暂停状态；4：已完成状态。
creator	创建人
source_config	载入配置
start_at	载入时间
end_at	结束时间
created_at	创建时间
updated_at	更新时间
total	返回数量

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task/list" 

headers = {
    "moi-key": "xxxxx"
}

response = requests.get(url, headers=headers)

print("Response Body:", json.dumps(response.json(), indent=4, ensure_ascii=False))

返回：

Response Body: {
    "code": "OK",
    "msg": "OK",
    "data": {
        "tasks": [
            {
                "id": "1889223922712281088",
                "source_connector_id": 100004,
                "source_connector_type": 4,
                "volume_id": "1889223879880048640",
                "volume_name": "b-vol1",
                "name": "",
                "status": 4,
                "creator": "admin",
                "source_config": {
                    "common_file_task_config": {
                        "uris": [
                            "红楼梦(通行本)简体横排.pdf"
                        ],
                        "load_mode_config": {
                            "load_interval_type": 4,
                            "interval": 0
                        }
                    }
                },
                "start_at": 1739261063,
                "end_at": 1739261640,
                "created_at": 1739261057,
                "updated_at": 1739261640
            }
        ],
        "total": 1
    }
}

载入任务更新

POST /task/update

输入参数：

参数	是否必填	含义
task_id	是	任务 id
load_mode_config	否	载入模式设置，interval 为载入周期，load_interval_type 表示载入周期单位和类型，0：未知的加载间隔类型，可作为默认的无效值）；1：按天进行加载，可能表示每天固定时间加载；2：按小时进行加载，可能表示每小时的某个固定时间加载 3：按分钟进行加载，可能表示每分钟的某个固定时刻加载；4：默认类型，仅加载一次。
uris	否	载入文件

示例：

import requests
import json
# API URL
url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task/update"  

headers = {
    "moi-key": "xxxxx"
}

body = {
    "task_id":"1889698919578107904",
    "load_mode_config":{
                      "load_interval_type":4
                   },
              "uris":["红楼梦 (通行本) 简体横排.pdf"]
}

response = requests.post(url, json=body, headers=headers)
print(response.json()) 

返回：

{'code': 'OK', 'msg': 'OK'}

载入任务删除

POST /task/delete

输入参数：

参数	是否必填	含义
task_id	是	任务 id

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task/delete/" 

headers = {
    "moi-key": "xxxxx"
}

body = {
    "task_id": "1234567890"
}

response = requests.post(url, headers=headers, json=body)

if response.status_code == 200:
    print(response.json()) 
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

返回：

{'code': 'OK', 'msg': 'OK'}

载入任务暂停

POST /task/pause

输入参数：

参数	是否必填	含义
task_id	是	任务 id

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task/pause" 

headers = {
    "moi-key": "xxxxx"
}

body= {
    "task_id": "1889613340219121664"
}

response = requests.post(url, headers=headers, json=body)

if response.status_code == 200:
    print(response.json())  # 打印返回的 JSON 数据
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

返回：

{'code': 'OK', 'msg': 'OK'}

载入任务恢复

POST /task/resume

输入参数：

参数	是否必填	含义
task_id	是	任务 id

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task/resume"  

headers = {
    "moi-key": "xxxxx"
}

data = {
    "task_id": "1889613340219121664"
}

response = requests.post(url, headers=headers, json=data)

if response.status_code == 200:
    print(response.json())  
else:
    print(f"请求失败，状态码：{response.status_code}, 错误信息：{response.text}")

返回：

{'code': 'OK', 'msg': 'OK'}

载入任务重试

POST /task/retry

输入参数：

参数	是否必填	含义
task_id	是	任务 id
ids	是	失败文件 id

示例：

import requests
import json

url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task/retry"
headers = {
    "moi-key": "xxxxx"
}

body = {
    "task_id": "1889074091616481280",
    "ids": ["1889074111245824000"]
}

response = requests.post(url, headers=headers,json=body)
print("Response Body:", json.dumps(response.json(), indent=4, ensure_ascii=False))

返回：

Response Body: {
    "code": "OK",
    "msg": "OK"
}

载入任务获取

GET /task/get

路径参数：

参数	是否必填	含义
task_id	是	任务 id

输出参数：

参数	含义
id	载入 id
source_connector_id	连接器 id
source_connector_type	连接器类型
volume_id	原始卷 id
volume_name	原始卷名称
status	载入任务状态，0：未知状态；1：正常执行中或可执行状态；2：正在暂停状态；3：已暂停状态；4：已完成状态。
creator	创建人
source_config	载入配置
start_at	载入时间
end_at	结束时间
created_at	创建时间
updated_at	更新时间
total	返回数量

示例：

import requests
import json

task_id = "1889613340219121664"
url = f"https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task/get?task_id={task_id}"

headers = {
    "moi-key": "xxxxx"
}

response = requests.get(url, headers=headers)
print("Response Body:", json.dumps(response.json(), indent=4, ensure_ascii=False))

返回：

Response Body: {
    "code": "OK",
    "msg": "OK",
    "data": {
        "task": {
            "id": "1889613340219121664",
            "source_connector_id": 100004,
            "source_connector_type": 4,
            "volume_id": "1889578498228068352",
            "volume_name": "b-vol2",
            "name": "",
            "status": 4,
            "creator": "admin",
            "source_config": {
                "common_file_task_config": {
                    "uris": [
                        "红楼梦(通行本)简体横排.pdf"
                    ],
                    "load_mode_config": {
                        "load_interval_type": 4,
                        "interval": 0
                    }
                }
            },
            "start_at": 1739355480,
            "end_at": 1739355480,
            "created_at": 1739353902,
            "updated_at": 1739355480
        }
    }
}

获取载入任务下的文件

GET /task/files

输入参数：

参数	是否必填	含义
task_id	是	任务 id
status	否	文件载入状态，0：状态未知或未定义；1：等待中；2：正在上传；3：已暂停；4：失败；5：成功；6：正在重试。
page	否	页码
page_size	否	当页展示最大文件数量

输出参数：

参数	含义
id	载入 id
name	文件名称
type	文件类型，支持： NIL = 0 TXT = 1 PDF = 2 IMAGE = 3 PPT = 4 WORD = 5 MARKDOWN = 6 CSV = 7 PARQUET = 8 SQL_FILES = 9 DIR = 10 DOCX = 11 PPTX = 12 WAV = 13 MP3 = 14 AAC = 15 FLAC = 16 MP4 = 17 MOV = 18 MKV = 19 PNG = 20 JPG = 21 JPEG = 22 BMP = 23
status	文件载入状态
size	文件大小
update_time	更新时间
user	创建人
start_at	载入时间
end_at	结束时间

示例：

import requests
import json

task_id = "1889613340219121664"
url = "https://freetier-01.cn-hangzhou.cluster.matrixonecloud.cn/task/files?task_id={task_id}"

headers = {
    "moi-key": "xxxxx"
}

params = {
    "task_id": 1889613340219121664
}

response = requests.get(url, headers=headers, params=params)

print("Response Body:", json.dumps(response.json(), indent=4, ensure_ascii=False))

返回：

Response Body: {
    "code": "OK",
    "msg": "OK",
    "data": {
        "total": 1,
        "total_success": 1,
        "total_failed": 0,
        "files": [
            {
                "id": "1889613341347389440",
                "name": "红楼梦(通行本)简体横排.pdf",
                "type": 2,
                "status": 5,
                "size": 6787457,
                "update_time": 1739353902,
                "other_metadata": "",
                "reason": "",
                "user": "admin",
                "start_time": 1739353902,
                "end_time": 0,
                "path": "/b-vol2/红楼梦(通行本)简体横排.pdf"
            }
        ]
    }
}