Я исследую немного UDS для регистрации в приложении, а затем использую другой процесс для отправки журналов на внешний сервер.В целом, кажется, что он работает нормально, но когда я тестировал его, я обнаружил, что если я отправляю некоторые журналы в цикле for, когда поток читается из сокета, он содержит больше «сообщений».
, вы можете найти коддля получения журналов здесь https://github.com/MattBlack85/alf (после установки вы можете запустить его с помощью alf /tmp/alf.sock http://127.0.0.1:8080)
, здесь вы можете найти небольшой пример отправки журналов https://gist.github.com/MattBlack85/86d620a306f16416a7f96a1a035984dc
.небольшой веб-сервер, позволяющий alf отправлять сюда журналы https://gist.github.com/MattBlack85/0638ef87eb077eb46879d6c90a30cf7a
, если цикл for не спит, в результате получается что-то вроде
[2018-12-18 13:12:39,798] [DEBUG] alf.worker - MSG from queue: b'{"time":"2018-12-18 13:12:39,797","name":"test","levelname":"DEBUG","message":"test 0","pathname":"logalf.py"}{"time":"2018-12-18 13:12:39,798","name":"test","levelname":"DEBUG","message":"test 1","pathname":"logalf.py"}{"time":"2018-12-18 13:12:39,798","name":"test","levelname":"DEBUG","message":"test 2","pathname":"logalf.py"}{"time":"2018-12-18 13:12:39,798","name":"test","levelname":"DEBUG","message":"test 3","pathname":"logalf.py"}{"time":"2018-12-18 13:12:39,798","name":"test","levelname":"DEBUG","message":"test 4","pathname":"logalf.py"}{"time":"2018-12-18 13:12:39,798","name":"test","levelname":"DEBUG","message":"test 5","pathname":"logalf.py"}'
во время небольшого перерываиз 1 мс все сообщения принимаются одно за другим.Я пытался закрыть все тяжелые процессы в моей ОС и оставить процессор свободным, но это не сработало.Это не большая проблема, так как я могу добавить терминатор при форматировании журнала JSON и разделить то, что читается из сокета, и поместить каждый элемент результирующего списка в очередь, но почему я вообще это вижу?