我正在尝试将pandas dataframe写入outputblob流,如下所示:
def main(myblob: func.InputStream,outputblob: func.Out[func.InputStream]):
logging.info(f"Python blob trigger function processed blob \n"
f"Name: {myblob.name}\n"
f"Blob Size: {myblob.length} bytes")
blobBinaryDataStream = io.BytesIO(myblob.read())
reader = fastavro.reader(blobBinaryDataStream)
# Load records in memory
records = [r for r in reader]
# Populate pandas.DataFrame with records
df = pd.DataFrame.from_records(records)
stream = io.StringIO()
df.to_csv(stream, sep=",")
outputblob.set(stream)
但是,它会将一个空文件写入blob。有人能帮忙吗
目前没有回答
相关问题 更多 >
编程相关推荐