LoongCollector支持采集配置级的优先级指定(iLogtail时代仅支持按Logstore指定优先级),通过分级调度机制实现关键流水线的优先处理:
优先级分配:每条流水线可配置优先级等级,高优先级流水线获得更多的处理时间片。
队列调度策略:Processor Runner线程从多个流水线的处理队列中获取事件时,按优先级加权轮询。高优先级队列中的事件被更频繁地取出处理。
发送优先级:在发送阶段同样按优先级调度,确保关键流水线的数据优先发送到下游。
资源公平性:在保证优先级的同时,低优先级流水线不会被完全饿死——每条流水线都有最低保证的处理时间片。
动态调整:当高优先级流水线无数据处理时,其空闲时间片会自动分配给其他流水线,避免资源浪费。
这种设计确保了多租场景下,关键业务的采集配置能获得优先的资源保障,同时不影响其他租户的基本服务质量。




