NIFI puts3Object处理器的默认重试机制

我正在使用nifi的puts3Object处理器将对象从onprem上传到AWS s3存储桶。 我相信根据分段的阈值,我们有两种上传类型,即单部分上传和分段上传。

对于multipart,请遵循3个步骤
1)s3.nitiateMultipartUpload, 2)s3.uploadPart 3)s3.completeMultipartUpload

在检查我发现的代码时,在completeMultipartUpload方法中,如果有任何服务器端异常(5 **),则它将重试3次(如AWS开发工具包的CompleteMultipartUploadRetryCondition类中一样, MAX_RETRY_ATTEMPTS是使用do while循环的值3)的常量变量。

我有2个问题

a)此默认重试机制(值为3)仅在s3.completeMultipartUpload方法中使用?我也找不到在单个对象上载中使用的任何重试代码。

b)如果要更改MaxErrorRetry值AWS ClientConfiguration,是否将其重试值更改为我设置的pe值,其恒定值为3。请确认。

c)如果B ans是YES。 然后,只有ClientConfiguration.MaxErrorRetry(myCostumValue)将起作用,或者

我还必须添加以下代码以重试策略。

ClientConfiguration.setRetryPolicy(new RetryPolicy(config.getRetryPolicy()。getRetryCondition(),config.getRetryPolicy()。getBackoffStrategy(),myCostumValue,true)

yndf345678 回答:NIFI puts3Object处理器的默认重试机制

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3122530.html

大家都在问