请求流gRPC客户端请求错误

Question

当我运行我的gRPC客户端，它试图将请求流式传输到服务器时，我收到了这个错误："TypeError： has typelist_iterator，但期望其中之一：bytes， unicode"

我需要以某种方式对我发送的文本进行编码吗？错误消息有一定的意义，因为我肯定是在传入一个迭代器。我从gRPC留档中假设这是需要的。（https://grpc.io/docs/tutorials/basic/python.html#request-streaming-rpc）无论如何，发送列表或字符串会产生类似的错误。目前我正在向请求中的服务器发送一个字符串的小测试列表，但我计划在未来流式传输具有非常大量文本的请求。

这是我的一些客户代码。

def gen_tweet_space(text):
    for tweet in text:
        yield tweet

def run():
 channel = grpc.insecure_channel('localhost:50050')
 stub = ProseAndBabel_pb2_grpc.ProseAndBabelStub(channel)

 while True:
     iterator = iter(block_of_text)
     response = stub.UserMarkov(ProseAndBabel_pb2.UserTweets(tweets=iterator))

以下是相关的服务器代码：

def UserMarkov(self, request_iterator, context):
        return ProseAndBabel_pb2.Babel(prose=markov.get_sentence(request_iterator.tweets))

这是定义rpc和消息的原型：

service ProseAndBabel {

rpc GetHaiku (BabelRequest) returns (Babel) {}
rpc GetBabel (BabelRequest) returns (Babel) {}
rpc UserMarkov (stream UserTweets) returns (UserBabel) {}
}

message BabelRequest{
  string ask = 1;
}

message Babel{
  string prose = 1;
}

message UserTweets{
  string tweets = 1;
}

message UserBabel{
  string prose = 1;
}

我已经成功地让非流式rpc工作，但是在为python应用程序的请求端流式处理找到演练时遇到了困难，所以我确信我在这里遗漏了一些东西。感谢您的指导！

Answer 1

您需要将请求的迭代器传递给gRPC客户端存根，而不是原型构造函数。当前代码尝试使用迭代器而不是单个字符串实例化UserTweets原型，从而导致类型错误。

response = stub.UserMarkov(ProseAndBabel_pb2.UserTweets(tweets=iterator))

相反，您需要有您的迭代器来返回ProseAndBabel_pb2. UserTweets的实例，每个实例都包装了您想要发送的请求字符串之一，并将迭代器本身传递给存根。类似于：

iterator = iter([ProseAndBabel_pb2.UserTweets(tweets=x) for x in block_of_text])
response = stub.UserMarkov(iterator)