问题描述
现在我在库的帮助下在内存中创建 Parquet 文件,并将其上传到 Azure Blob storage
。但是,这次我想要更简单的东西,即只是一个文本文件,用于将 DateTime.UtcNow
写入内存中的文本文件并将其上传到 Azure。
到目前为止我的代码:
BlobServiceClient BlobServiceClient = new BlobServiceClient("my_code");
var containerClient = BlobServiceClient.GetBlobContainerClient("my_container");
var blobClient = containerClient.GetBlockBlobClient($"path/to/specific/directory/file.parquet");
using (var outStream = await blobClient.OpenWriteAsync(true).ConfigureAwait(false))
using (ChoParquetWriter parser = new ChoParquetWriter(outStream))
{
parser.Write(data_list);
}
如何在没有 ChoParquetWriter
(我正在使用的库的一部分)的情况下在内存中创建文本文件?
更新:找到解决方案
using (var outStream = await blobClient4.OpenWriteAsync(true).ConfigureAwait(false))
{
byte[] bytes = null;
using (var ms = new MemoryStream())
{
TextWriter tw = new StreamWriter(ms);
tw.Write(RequestTime.ToString());
tw.Flush();
ms.Position = 0;
bytes = ms.ToArray();
ms.Writeto(outStream);
}
}
有更简单的方法吗?如果不是这样没关系
解决方法
如果直接使用 UploadAsync
或 Upload
方法会简单一些。
例如:
//other code
var blobClient4 = containerClient.GetBlockBlobClient("xxx");
using (var ms = new MemoryStream())
{
StreamWriter writer = new StreamWriter(ms);
writer.Write(RequestTime.ToString());
writer.Flush();
ms.Position = 0;
await blobClient4.UploadAsync(ms);
}
,
我可能过于简单化了,但是您创建的文本编写器不能直接写入 outStream 吗?只需确保将文本编写器包装在 using 语句中,以便它正确刷新...