我一直在尝试探索是否有办法重试createTask 函数。原因是因为我不时遇到截止日期超出错误,如下所示:
错误:4 DEADLINE_EXCEEDED:Object.exports.createStatusError (/srv/node_modules/grpc/src/common.js:91:15) 超过 Object.onReceiveStatus (/srv/node_modules/grpc/src/client_interceptors.js:1204) :28) 在 InterceptingListener._callNext (/srv/node_modules/grpc/src/client_interceptors.js:568:42) 在 InterceptingListener.onReceiveStatus (/srv/node_modules/grpc/src/client_interceptors.js:618:8) 在回调 ( /srv/node_modules/grpc/src/client_interceptors.js:845:24)
阅读 createTask 函数背后的代码,我发现默认的超时配置只有 10 秒。
目前,我试图通过这样做将超时时间延长到 30 秒(我相信这是最大值):
try {
console.log("Sending task %j", task);
const callOptions = {
timeout: 30000
};
// Send create task request.
const [response] = await client.createTask(request, callOptions);
const name = response.name;
console.log(`Created task ${name}`);
} catch (error) {
console.error("CREATE_TASK_ERROR::", error);
}
它似乎有效。但是,如果 API 无法在 30 秒内响应,我也想介绍一下这种情况。
我试过这段代码:
try {
console.log("Sending task %j", task);
const callOptions = {
timeout: 2000, // I've set it to 2 seconds to be able to reproduce the deadline exceeded error easily
retry: {
initial_retry_delay_millis: 100,
retry_delay_multiplier: 1.3,
max_retry_delay_millis: 60000,
initial_rpc_timeout_millis: 20000,
rpc_timeout_multiplier: 1.0,
max_rpc_timeout_millis: 20000,
total_timeout_millis: 300000
}
};
// Send create task request.
const [response] = await client.createTask(request, callOptions);
const name = response.name;
console.log(`Created task ${name}`);
} catch (error) {
console.error("CREATE_TASK_ERROR::", error);
}
但我没有看到 createTask 被重试。但是根据这里的评论,我们应该能够覆盖包括重试在内的默认设置。
我究竟做错了什么?请帮忙。