当前位置: 首页 > 知识库问答 >
问题:

如何使用Java在Cosmos DB中设置重试策略?

闻人宜
2023-03-14

如何使用Java设置重试策略,将记录推到cosmosDB。

如果第一次推记录失败,我想重试推记录。我想在间隔2秒后重试推5次。

参考链接:https://docs.microsoft.com/bs-latn-ba/azure/cosmos-db/performance-tips-java

代码:

retryOptions = new RetryOptions();
retryOptions.setMaxRetryAttemptsOnThrottledRequests(5);
retryOptions.setMaxRetryWaitTimeInSeconds(10);
connectionPolicy = new ConnectionPolicy();
connectionPolicy.setRetryOptions(retryOptions);
documentClient = new DocumentClient(END_POINT,
                MASTER_KEY, connectionPolicy,
                ConsistencyLevel.Session);

共有1个答案

夏青青
2023-03-14

您可以使用ConnectionPolicy.setRetryOptions(RetryOptions RetryOptions)方法,并创建RetryOption的实例,其中SetmaxRetryAttriputsOnThrottleDreQuests5SetmaxRetryWaittimeinSeconds(2秒x 5次重试尝试)。

 类似资料:
  • 我在Android上使用Volley作为网络库。我在使用时遇到了“功能受限”的问题。它似乎是一个非常有用的类,带有缓存和其他功能,所以我想继续使用它。但是,它不允许访问它创建的对象。结果,我不能做一些在其他情况下可以做的事情(比如在请求上设置一个标记以将其从队列中取消)。 我当前的问题是-如何对使用发出的请求设置重试策略?

  • 问题内容: 我在设置值的Keras后端功能上遇到麻烦。我正在尝试将模型从PyTorch转换为Keras,并尝试设置Keras模型的权重,但是权重似乎没有被设置。注意:我实际上并没有使用np.ones进行设置,仅以示例为例。 我试过了… 加载现有模型 创建一个简单的模型 然后使用set_weights或set_value 要么… 之后,我将调用以下任一方法: 而且似乎没有设置任何权重。返回与以前相同

  • 问题内容: 我在服务中使用了异步方法(Spring 3 @Async注释)。而且我有一个问题-产生的线程没有安全上下文。原因是Spring Security默认为其上下文持有者使用策略。但是我需要使用策略。目前,我在中设置了策略。但是我认为这不是一个好习惯。 那么如何在上下文配置文件中进行设置? Spring Security的版本是3.0.0。 问题答案: 你可以将环境变量设置为。你还可以使用一

  • 有人知道解决这个问题的办法吗?我已经测试了在Modulepath和classpath中添加来自Selenium的外部jar。然而,两者似乎有相同的结果和错误。

  • 问题内容: 我正在尝试设置一个环境变量,然后将其读回以验证它是否确实被设置。 我有以下内容: 但是,它看起来总是空的,这意味着它可能设置不正确。 我的exec命令正确吗?javadocs声明它可以将字符串参数作为命令。 有任何想法吗? 问题答案: 这行不通。当您开始一个新过程时,该过程将收到环境 的副本 。然后,它对环境变量所做的任何更改都将在该副本中进行,并且在任何时候都不会对调用方可见。 您实

  • 问题内容: 如何在Java中使用org.json.JSONObject将值设置为null?我肯定可以通过使用isNull来读取值是否为null,但是当我将其设置为null时,它只会忽略我: 问题答案: 尝试设置而不是: 用于明确定义没有值的名称的哨兵值。与null不同,具有以下值的名称: 显示在names()数组中 出现在keys()迭代器中 为has(String)返回true 不要抛出get(