如何使用azure函数blob触发器将数据帧写入blob

2024-05-13 00:00:19 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在尝试将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。有人能帮忙吗


Tags: iniodataframepandasdfstreamblobreader