Как я решил проблему, когда библиотеки gRPC отправляли информацию в Kafka? [закрыто] ⇐ Python

[Anonymous]

У меня проблема с GRPC, которую я не понимаю, потому что у меня все компоненты grpc, как прото, так и grpc-сервер, сделаны в nodejs, дело в том, что по выводам кодов мне приходится перегенерировать автоматический .proto, который он занимает, но у меня возникает проблема с библиотекой, которую я не смог решить, я удаляю grpcio-tools и переустанавливаю его, но изменений нет, прикрепляю свой github проекта, контекст работы. Вещь заключается в том, что у меня есть система заказов, которую мне нужно создать, и я должен использовать клиент и сервер grpc для отправки данных в Kafka, чтобы позже сохранить их в elasticSearch и создать другие микросервисы.
При выполнении файла cliente.py у меня возникает следующая ошибка. Chatgpt сообщает мне, что это, должно быть, проблема с .proto, и мне нужно сгенерировать его снова, но он ни в одном не сработал. кстати, поскольку это больше не ошибка набора данных.

Код: Выделить всё

PS C:\Users\mati-\Desktop\Tarea 2 SD.2\Tarea2Sistemas\python-client\proto> & C:/Users/mati-/AppData/Local/Microsoft/WindowsApps/python3.12.exe "c:/Users/mati-/Desktop/Tarea 2 SD.2/Tarea2Sistemas/python-client/cliente.py"
Conectado al servidor gRPC en localhost:50051
Traceback (most recent call last):
File "c:\Users\mati-\Desktop\Tarea 2 SD.2\Tarea2Sistemas\python-client\cliente.py", line 71, in 
procesar_dataset(ruta_dataset, stub)
File "c:\Users\mati-\Desktop\Tarea 2 SD.2\Tarea2Sistemas\python-client\cliente.py", line 49, in procesar_dataset
realizar_pedido(stub, nombre_producto, precio, cliente_email, metodo_pago, banco, tipo_tarjeta, calle, numero, region)
File "c:\Users\mati-\Desktop\Tarea 2 SD.2\Tarea2Sistemas\python-client\cliente.py", line 26, in realizar_pedido
respuesta = stub.RealizarPedido(pedido)
^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\mati-\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.12_qbz5n2kfra8p0\LocalCache\local-packages\Python312\site-packages\grpc\_channel.py", line 1181, in __call__
return _end_unary_response_blocking(state, call, False, None)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\mati-\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.12_qbz5n2kfra8p0\LocalCache\local-packages\Python312\site-packages\grpc\_channel.py", line 1006, in _end_unary_response_blocking
raise _InactiveRpcError(state)  # pytype: disable=not-instantiable
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
grpc._channel._InactiveRpcError: 

Теперь я надеюсь, что смогу отправить все данные в kafka и выполнить необходимый мне анализ.

Подробнее здесь: https://stackoverflow.com/questions/791 ... n-to-kafka