如何将数据插入到 Azure 表存储中

Question

我正在寻找一个简单的 C# 程序来将数据插入 Azure blob 表存储。 有人可以帮忙吗？

请让我知道下面的代码有什么问题？（代码没有抛出任何错误，只是没有创建任何表/插入数据）

  
 using System;
using System.Threading.Tasks;
using Azure.Data.Tables;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Table;
using TableEntity = Microsoft.WindowsAzure.Storage.Table.TableEntity;
using TableClientConfiguration = Microsoft.Azure.Cosmos.Table.TableClientConfiguration;
public class CustomerEntity : TableEntity
{
    public CustomerEntity(string lastName, string firstName)
    {
        this.PartitionKey = lastName;
        this.RowKey = firstName;
    }
    public CustomerEntity() { } // the parameter-less constructor must be provided
    public string Email { get; set; }
    public string PhoneNumber { get; set; }
}
class Program
{
    static void Main(string[] args) {
        
        var tableName = "TestTempTable";        
        var storageConnectionString = "DefaultEndpointsProtocol=https;AccountName=**********;AccountKey=*******/****==;EndpointSuffix=core.windows.net";        
        try
        {
            Console.WriteLine("START");            
            var storageAccount = CloudStorageAccount.Parse(storageConnectionString);            
            var tableClient = storageAccount.CreateCloudTableClient();
            var table = tableClient.GetTableReference(tableName);
            table.CreateIfNotExistsAsync();            
            Console.WriteLine($"CloudTable name is : {tableClient}");
            // Create a new customer entity.
            CustomerEntity customer1 = new CustomerEntity("Harp", "Walter");
            customer1.Email = "xyz@xyz.com";
            customer1.PhoneNumber = "1234568";            
            table.ExecuteAsync(TableOperation.Insert(customer1));            
            Console.WriteLine("Records Inserted");
            Console.WriteLine("END");
        }
        catch (Exception e)
        {
            Console.WriteLine("Encountered Exception - "+e);
        }
    }
}   

谢谢， 保罗。

Answer 1

您的程序没有抛出任何错误并且没有插入实体的原因是您没有等待异步操作并且您的程序在它成功之前终止。这就是为什么“插入的记录”之类的行像正常程序执行一样运行的原因。考虑在您的程序中的这两行中使用await：

await table.CreateIfNotExistsAsync();

await table.ExecuteAsync(TableOperation.Insert(customer1));