SLS 的 OpenSearch 数据导入功能采用滑动时间窗口机制推进增量边界,通过配置时间字段、时间格式和时区来确保边界计算的准确性。为应对源端 refresh/写入延迟导致的迟到数据,可配置"最大延迟时间窗口",让增量边界向过去回退以覆盖延迟到达的数据。如果某个时间区间在写入 SLS 过程中异常中断,系统会自动重新拉取同一时间区间的数据进行补偿。用户还可以自定义"单次查询时间区间"来控制每次拉取的窗口长度,在实时性和源端压力之间做平衡。此外,导入任务提供统计与报表功能,可实时观测吞吐、延迟、失败与积压情况,便于及时发现和处理数据遗漏问题。
加载中...