我正在使用python (aioredis)和redis流。
我有一个生产者-多个(分组的)消费者场景,并希望确保消费者以有序的方式处理发送到流的(批量)消息,这意味着:当第一个消息完成时,处理流中的下一个消息,依此类推。这也意味着消费者组中的一个消费者正在一次处理,而其他消费者将等待。
我还希望依赖于第二个、第三个等消费者组中的有序处理-所有这些都依赖于发送到一个流的相同消息。含义:
message 1 ... n -> stream1
ordered processing within group 1 ... n
whereas consumer 1 ... n per gro