Возможно ли в Python 3 читать JSON-объекты из socket?

Question

[nivs]

По сети время от времени отправляются JSON-объекты. Если ли специализированное решение, чтобы постоянно читать из сокета данные, и когда придёт один JSON полностью, отправлять его на обработку, затем сразу же ожидать следующий JSON-объект, чтобы его тоже отправить на обработку и так далее? Сокет не должен разрываться, объекты будут поступать время от времени по одному или пачками. В идеале получать данные как после json.loads() .

Я попробовал socket.makefile() вместе с ijson - хорошего ничего не вышло, cpiekarski.com/2011/05/09/super-easy-python-json-c... написан для 2ого и в 3й не вышло переделать.

Работать должно как под Linux, так и под Windows.

Comments

[StrangeAttractor]

Мне кажется проще написать промежуточный сервер на C++ или Java, который будет слушать сокет, и в нужный момент дёргать Python-сервер по HTTP.

[nivs]

Ваш пример не подходит для моей задачи, мне нужен именно Python-модуль. "Проще" накостылять такой парсер самостоятельно, но меня интересуют готовые оптимизированные решения.

[LittleBuster]

@nivs: я делал через socket.socket - делал json.dumps и отправлял в сокет байты .encode("utf-8")

[Александр Ручкин]

@nivs, а JSON-объекты ничем не разделяются? Т.е. просто летят подряд? '{...1-st object...}{...2-nd object...}'

[nivs]

@LittleBuster: а если объект не полностью пришёл, то что?
@VoidEx: пока что попросил вторую сторону разделять объекты двумя переводами строк и фильтровать содержимое, чтобы внутри них не было '\n\n', но это определённо не выход.

[Александр Ручкин]

@Nivs, у меня так и сделано, только не двумя, а одним. Читаем чанки и наращиваем, пока не встретим '\n', затем всё, что перед переводом строки - кормим json.loads, а всё, что после - в новый кусок. Фильтровать содержимое не нужно, в [не pretty] json не должно быть перевода строки, внутри строк он экранируется в "\\n".

Answer 1

[Александр Ручкин]

Если есть возможность повлиять на то, каким именно образом прилетает JSON, то можно попросить разделять их, к примеру, переводом строки. Перевод строки в самом [не pretty] JSON встречаться не может, в строках он будет экранирован, а потому можно наращивать прочитанные из сокета данные до тех пор, пока не встретится перевод строки, и то, что перед ним, кормить json.loads, а остальное продолжать наращивать.

Comments

[nivs]

Спасибо, так и сделаем.