Atlas Stream Processing监控和警报

流处理器监控方法

Atlas Stream Processing 提供以下方法来按需报告流处理器的相关信息：

• sp.processor.sample()

• sp.processor.stats()

sp.processor.sample()方法允许您查看所选当前正在运行的流处理器输出的文档的小样本。用户可以将采样结果与预期结果进行比较，以诊断聚合管道设计中的任何错误。

sp.processor.stats()方法返回有关您选择的流处理器的各种运行时统计信息，包括但不限于：

• 摄取的消息数

• 成功处理的消息数

• 发送到死信队列的消息数量

• 管道状态的内存大小

• 管道定义

流处理器警报

当流处理器状态发生变化时，Atlas Stream Processing 会触发警报。有关可用 Atlas Stream Processing 警报的列表，请参阅Atlas Stream Processing 警报。要了解有关警报配置的更多信息，请参阅配置警报设置。