1
У меня есть переменная скорость небольших сообщений, входящих в RabbitMQ (5-60 000/sec), и мне нужно записать их в файлы для фазы обработки. Я хотел бы, чтобы каждый файл останавливался на 50k строк или последние 5 минут данных (что когда-либо было на первом месте). Я не хочу запускать входящие сообщения, пока весь файл не будет написан, не очищен и не закрыт. Есть простой способ сделать это? Порядок сообщений не имеет значения.Запись файлов с помощью RabbitMQ