当调用限制单次最多 20 个 sku 的 put api 时，需将大型 json 文件中的 sku 数据拆分为多个小批次，逐批发送请求，避免超限错误。本文提供完整 php 实现方案，含 json 解析、分块逻辑、curl 批量调用及错误处理。
当调用限制单次最多 20 个 sku 的 put api 时，需将大型 json 文件中的 sku 数据拆分为多个小批次，逐批发送请求，避免超限错误。本文提供完整 php 实现方案，含 json 解析、分块逻辑、curl 批量调用及错误处理。
在实际电商或库存系统集成中，常遇到第三方 API 对单次请求的资源数量设限（如本例中「20 SKU per submission」）。直接提交含 1000+ SKU 的完整 JSON 会触发服务端校验失败，返回 400 Bad Request 或类似提示。根本解决思路不是绕过限制，而是主动适配——将大 payload 拆解为合规的小批次，并串行/并发提交。
✅ 正确做法：分批处理 + 循环提交
以下是一个健壮、可复用的 PHP 实现，支持从 ti.json 读取全部 SKU，按每批 20 条切分，并逐一发起 PUT 请求：
<?php
// 1. 读取并解析原始 JSON 文件
$jsonContent = file_get_contents('ti.json');
$data = json_decode($jsonContent, true);
if (json_last_error() !== JSON_ERROR_NONE) {
die("JSON 解析失败: " . json_last_error_msg());
}
if (!isset($data['data']) || !is_array($data['data'])) {
die("JSON 格式错误：缺少 'data' 数组");
}
$allSkus = $data['data'];
$batchSize = 20;
$batches = array_chunk($allSkus, $batchSize); // 拆分为每组 20 个 SKU 的数组
echo "共 " . count($allSkus) . " 个 SKU，将分为 " . count($batches) . " 批提交。\n";
// 2. 遍历每个批次，构造并发送 PUT 请求
$successCount = 0;
$failedBatches = [];
foreach ($batches as $index => $batch) {
$payload = ['data' => $batch];
$jsonPayload = json_encode($payload, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => 'https://api.example.com/products/updateSkus', // ✅ 替换为真实完整 URL
CURLOPT_RETURNTRANSFER => true,
CURLOPT_CUSTOMREQUEST => 'PUT',
CURLOPT_POSTFIELDS => $jsonPayload,
CURLOPT_HTTPHEADER => [
'Authorization: Bearer xxxxxxxxxxxxxxx', // ✅ 替换为真实 Token
'Content-Type: application/json',
'Content-Length: ' . strlen($jsonPayload)
],
CURLOPT_TIMEOUT => 30,
CURLOPT_FOLLOWLOCATION => true,
CURLOPT_SSL_VERIFYPEER => false, // 生产环境请启用证书验证
]);
$response = curl_exec($curl);
$httpCode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
$error = curl_error($curl);
curl_close($curl);
if ($httpCode >= 200 && $httpCode < 300) {
echo "[✓] 第 " . ($index + 1) . " 批 (" . count($batch) . " SKU) 提交成功\n";
$successCount++;
} else {
echo "[✗] 第 " . ($index + 1) . " 批失败 (HTTP {$httpCode}): " . substr($response, 0, 200) . "\n";
$failedBatches[] = ['batch_index' => $index + 1, 'http_code' => $httpCode, 'response' => $response];
}
// ⚠️ 可选：添加轻微延迟，避免请求过于密集（尤其对方有频控）
usleep(200000); // 200ms
}
// 3. 输出汇总结果
echo "\n=== 提交完成 ===\n";
echo "成功批次：{$successCount}/" . count($batches) . "\n";
if (!empty($failedBatches)) {
echo "失败批次详情：\n";
foreach ($failedBatches as $fail) {
echo "- 批次 {$fail['batch_index']}，状态码 {$fail['http_code']}\n";
}
}
?>? 关键注意事项
- URL 必须完整：CURLOPT_URL 应填写带协议（https://）和域名的绝对路径，而非相对路径 /products/updateSkus（否则 cURL 无法发起有效请求）。
- Token 安全管理：勿硬编码 Bearer Token，建议通过环境变量（如 $_ENV['API_TOKEN']）或配置文件加载。
- 错误响应解析：生产环境中应 json_decode($response, true) 进一步检查返回体中的 error 字段，实现精细化重试逻辑。
- 并发优化（进阶）：若性能要求高，可用 curl_multi_* 函数实现并行提交（注意控制并发数，如 5~10 路），但需谨慎处理共享资源与错误隔离。
- 日志与监控：关键步骤（如每批次起止、耗时、响应头）建议写入日志文件，便于故障追溯。
通过以上结构化分批策略，你不仅能稳定提交 1000+ SKU，还能清晰掌控执行过程、快速定位异常批次，真正实现大规模数据的安全、可靠同步。
