Transmisión de datos en gRPC python con solicitud de iterador pero obtengo “¡Excepción al iterar las solicitudes!”

Intenté usar gRPC python para realizar una comunicación de transmisión bidireccional, pero hay un problema en la solicitud del lado del cliente…

Aquí está mi prototipo:

service ABC {
    rpc DataTransmission (stream DataTransmissionRequest) returns (stream DataTransmissionResponse);
}

Mensaje DataTransmissionRequest {
bytes data = 1;
string ticket = 2;
}

Mensaje DataTransmissionResponse {
bytes data = 1;
}

Aquí está el código del cliente para generar una solicitud de iterador y llamar a la función dataTransmission:

def generateRequests():
        req_msgs = [
            (b"123", "sySJZDV9Rb8dyqt1"),
            (b"123"),
            (b"123"),
            (b"123"),
            (b"123"),
            (b"123"),
        ]
        iter = 0
        for (req, ticket) in req_msgs:
            print("(req, ticket) =", (req, ticket))
            if iter == 0:
                request = ABC_pb2.DataTransmissionRequest(data=req, ticket=ticket)
            else:
                request = ABC_pb2.DataTransmissionRequest(data=req)
            iter += 1
            print("iter =", iter)
            yield request

#my_queue = queue.SimpleQueue()
with grpc.insecure_channel(addr) as channel:
    stub = ABC_pb2_grpc.ServiceProxyStub(channel)

    data_transmission_resp = stub.DataTransmission(generateRequests())
    print("data_transmission_resp =", data_transmission_resp)
    ##print("data_transmission_resp =", list(data_transmission_resp))
    ## use the results
    for data_trans in data_transmission_resp:
        print(data_trans)

Pero obtuve el siguiente error:

grpc.channel.MultiThreadedRendezvous: <multithreadedrendezvous of rpc that terminated with:
        status = statuscode.unknown
        details = "exception iterating requests!"
        debug_error_string = "none"

¿por qué ocurre este error? y ¿es esta la forma correcta de usar la comunicación bidireccional grpc en python?

luego, hay algunos mensajes que mencionan el siguiente método:

    my_queue = queue.simplequeue()
    with grpc.insecure_channel(addr) as channel:
        stub = abc_pb2.grpc.serviceproxystub(channel)

    my_queue.put(generaterequests())
    data_transmission_resp = stub.datatransmission(iter(my_queue.get, none))

también obtengo el mismo error… of=”” rpc=”” that=”” terminated=”” with:=”” status=”StatusCode.UNKNOWN” details=”Exception iterating requests!” debug_error_string=”None” ="" ¿por="" qué="" ocurre="" este="" error?="" y="" ¿es="" esta="" la="" forma="" correcta="" de="" usar="" la="" comunicación="" bidireccional="" grpc="" en="" python?="" luego,="" hay="" algunos="" mensajes="" que="" mencionan="" el="" siguiente="" método:=""=”” my_queue=”queue.SimpleQueue()” with=”” grpc.insecure_channel(addr)=”” as=”” channel:=”” stub=”ABC_pb2.grpc.ServiceProxyStub(channel)” my_queue.put(generaterequests())=”” data_transmission_resp=”stub.DataTransmission(iter(my_queue.get,” none))=”” “`=”” también=”” obtengo=”” el=”” mismo=””></multithreadedrendezvous of rpc that terminated with:
status = statuscode.unknown
details = “exception iterating requests!”
debug_error_string = “none”

¿por qué ocurre este error? y ¿es esta la forma correcta de usar la comunicación bidireccional grpc en python?

luego, hay algunos mensajes que mencionan el siguiente método:

my_queue = queue.simplequeue()
with grpc.insecure_channel(addr) as channel:
    stub = abc_pb2.grpc.serviceproxystub(channel)

my_queue.put(generaterequests())
data_transmission_resp = stub.datatransmission(iter(my_queue.get, none))

“`

también obtengo el mismo error…>