Refine write option
This commit is contained in:
@@ -185,7 +185,7 @@ def create_write_options() -> WriteOptions:
|
|||||||
return WriteOptions(
|
return WriteOptions(
|
||||||
jitter_interval=200, # 添加抖动以避免同时写入
|
jitter_interval=200, # 添加抖动以避免同时写入
|
||||||
max_retry_delay=30000, # 最大重试延迟(毫秒)
|
max_retry_delay=30000, # 最大重试延迟(毫秒)
|
||||||
max_retries=5, # 最大重试次数(0 表示不重试)
|
# max_retries=5, # 最大重试次数(0 表示不重试) #DingZQ, 2025-05-10
|
||||||
batch_size=10_000, # 每批次发送10,000个点
|
batch_size=10_000, # 每批次发送10,000个点
|
||||||
flush_interval=10_000, # 10秒强制刷新
|
flush_interval=10_000, # 10秒强制刷新
|
||||||
retry_interval=5_000 # 失败重试间隔5秒
|
retry_interval=5_000 # 失败重试间隔5秒
|
||||||
|
|||||||
Reference in New Issue
Block a user