批量上传客户名单(BatchUploadCustomerManagement)
通过文件URL批量上传客户名单数据。上传为异步操作,返回上传任务ID用于状态跟踪。
前提条件
-
已安装SDK。
-
已获取并使用AccessKey的方式,请参考获取AccessKey并配置到环境变量。
-
已获取CustomerListId(客户名单ID)。调用QueryCustomerManagementList查询客户名单列表,从返回参数Records[].Id获取。
请求参数
|
名称 |
类型 |
必填 |
描述 |
示例值 |
|
Action |
String |
是 |
要执行的操作。取值:BatchUploadCustomerManagement。 |
BatchUploadCustomerManagement |
|
Version |
String |
是 |
API版本号。格式为:YYYY-MM-DD。取值:2025-11-27。 |
固定为2025-11-27 |
|
CustomerListId |
Number |
是 |
客户名单 ID |
1001 |
|
FileName |
String |
是 |
上传文件名称 |
customers_202601.xlsx |
|
FileUrl |
String |
是 |
文件下载URL(需可公网访问) |
https://example.com/customers.xlsx |
响应参数
|
名称 |
类型 |
描述 |
示例值 |
|
RequestId |
String |
请求ID。 |
xxxx-xxxx-xxxx |
|
Success |
Boolean |
请求是否成功。 |
True |
|
Code |
String |
错误码。请求成功时为空。 |
None |
|
Message |
String |
错误信息或成功提示。 |
操作成功 |
|
Data |
Object |
返回数据,包含Success, Message, UploadTaskId等字段,具体说明请参见下方返回参数说明。 |
使用示例
Python
import json
import os
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_tea_openapi.client import Client as OpenApiClient
from alibabacloud_tea_util import models as util_models
from alibabacloud_openapi_util.client import Client as OpenApiUtilClient
def main():
config = open_api_models.Config(
access_key_id=os.getenv("ACCESS_KEY_ID"),
access_key_secret=os.getenv("ACCESS_KEY_SECRET"),
)
config.endpoint = "thirdswaicall.aliyuncs.com"
config.protocol = "HTTPS"
client = OpenApiClient(config)
params = open_api_models.Params(
style="RPC",
version="2025-11-27",
action="BatchUploadCustomerManagement",
method="POST",
pathname="/",
protocol="HTTPS",
auth_type="AK",
req_body_type="json",
body_type="json",
)
body = {'CustomerListId': 1001, 'FileName': 'customers_202601.xlsx', 'FileUrl': 'https://example.com/customers.xlsx'}
request = open_api_models.OpenApiRequest(query=OpenApiUtilClient.query(body))
runtime = util_models.RuntimeOptions(autoretry=True, max_attempts=3)
try:
resp = client.call_api(params, request, runtime)
print(json.dumps(resp.get("body", {}), ensure_ascii=False, indent=2))
except Exception as e:
print(f"调用失败: {e}")
if __name__ == "__main__":
main()
Java
import com.aliyun.teaopenapi.Client;
import com.aliyun.teaopenapi.models.Config;
import com.aliyun.teaopenapi.models.OpenApiRequest;
import com.aliyun.teaopenapi.models.Params;
import com.aliyun.teautil.models.RuntimeOptions;
import com.google.gson.Gson;
import java.util.HashMap;
import java.util.Map;
public class Demo {
public static void main(String[] args) throws Exception {
// 初始化配置
Config config = new Config()
.setAccessKeyId(System.getenv("ACCESS_KEY_ID"))
.setAccessKeySecret(System.getenv("ACCESS_KEY_SECRET"))
.setEndpoint("thirdswaicall.aliyuncs.com")
.setProtocol("HTTPS");
Client client = new Client(config);
// 设置 API 参数
Params params = new Params()
.setStyle("RPC")
.setVersion("2025-11-27")
.setAction("BatchUploadCustomerManagement")
.setMethod("POST")
.setPathname("/")
.setProtocol("HTTPS")
.setAuthType("AK")
.setReqBodyType("json")
.setBodyType("json");
// 构建请求参数
Map<String, Object> body = new HashMap<>();
body.put("CustomerListId", 1);
body.put("FileName", "\u793a\u4f8b\u503c");
body.put("FileUrl", "\u793a\u4f8b\u503c");
OpenApiRequest request = new OpenApiRequest()
.setQuery(com.aliyun.openapiutil.Client.query(body));
// 设置运行时选项(自动重试)
RuntimeOptions runtime = new RuntimeOptions()
.setAutoretry(true)
.setMaxAttempts(3);
try {
// 调用 API
Map<String, ?> response = client.callApi(params, request, runtime);
Gson gson = new Gson();
System.out.println(gson.toJson(response.get("body")));
} catch (Exception e) {
System.err.println("调用失败: " + e.getMessage());
}
}
}
返回示例
{
"Success": true,
"Code": null,
"Message": "操作成功",
"RequestId": "xxxx-xxxx-xxxx",
"Data": {
"Success": true,
"Message": "上传任务已创建",
"UploadTaskId": 5001
}
}
具体的处理结果在Data节点中,以下为Data节点的参数说明。
|
名称 |
类型 |
描述 |
示例值 |
|
Success |
Boolean |
操作是否成功 |
true |
|
Message |
String |
操作结果说明 |
上传任务已创建 |
|
UploadTaskId |
Number |
上传任务ID,用于查询上传进度 |
5001 |
错误信息
如果执行报错,请参考错误信息进行解决。