根据link,我能够从本地文件夹传递镶木地板文件,并能够将数据转换为 json 格式。以下是示例代码
MemoryStream jsonMs = new MemoryStream();
using (var r = new ChoParquetReader(FILE_NAME))
{
using (var w = new ChoJSONWriter(jsonMs))
w.Write(r);
}
任何人都可以帮我解决如何传递 Azure blob 中存在的文件路径吗? 预先感谢。
由于
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:代码未经测试。