我们运行了一个Google批处理作业,它将数据记录写入一个pubsub管道,并有一个单独的流作业,它使用“pubsub to elasticsearch”流模板从PubSub管道中提取数据,并将更新写入我们的但是,我们不得不终止写入Elastic的流作业,因为在1次尝试之后,我们遇到了多个“向ES写入错误”。再也不允许“错误”了。从PubSub读取并写入Elasticsearch的任务是写入不是流索引的索引。它实际上
我有一个api,在这个api中,服务器向客户端发送数据流。在服务器端,填充流对象。我可以通过在发送之前写入服务器上的一个文件来验证这一点。但是,当客户端接收到流并尝试将其写入内存时,它总是导致一个空文件。以下是我的代码 TL;DR:从接口发送流不为空,客户端接收并尝试写入时为空 服务器端发送io.BytesIO对象 from io import BytesIO
from fastapi import FastAPIapp = Fast