如何在 ChoParquetReader 方法中传递 Azure blob 文件路径 url?

问题描述 投票:0回答:1

根据link,我能够从本地文件夹传递镶木地板文件,并能够将数据转换为 json 格式。以下是示例代码

MemoryStream jsonMs = new MemoryStream();
using (var r = new ChoParquetReader(FILE_NAME))
                {
                    using (var w = new ChoJSONWriter(jsonMs))
                        w.Write(r);
                }

任何人都可以帮我解决如何传递 Azure blob 中存在的文件路径吗? 预先感谢。

c# blob parquet choetl
1个回答
0
投票

由于

ChoParquetReader
接受任何内存流作为输入,只需打开 Azure blob 进行读取并将其传递给读取器。

供您参考,此示例可能会有所帮助

BlobServiceClient blobServiceClient = new BlobServiceClient("connectionString");
var desContainer = blobServiceClient.GetBlobContainerClient("containerName");
var desBlob= desContainer.GetBlockBlobClient("PARQUET file");

using (var outStream = await desBlob.OpenReadAsync(true).ConfigureAwait(false))
using (ChoParquetReader parser = new ChoParquetReader(outStream)
       Configure(c => DetectEncodingFromByteOrderMarks = false)
      )
{
}

PS:代码未经测试。

© www.soinside.com 2019 - 2024. All rights reserved.