Devlooped.TableStorage.MessagePack.Source 5.2.0

仅用于与基于文档的存储库一起使用的MessagePack二进制序列化程序。

用法

  var repo = DocumentRepository.Create<Product>(..., serializer: MessagePackDocumentSerializer.Default);

注意：为了使序列化工作，必须像平常一样使用MessagePack属性。

文档存储

DocumentRepository.Create和DocumentPartition.Create工厂方法提供了对基于文档的存储的访问权限，公开了一个类似于基于列的存储的API。

文档存储库会将实体作为单个文档列持久化，同时提供类型和版本信息来处理在应用级别的版本控制。

该API与基于列的存储库大致相同（文档存储库实现了相同的底层 ITableStorage接口）

public record Product(string Category, string Id) 
{
  public string? Title { get; init; }
  public double Price { get; init; }
  public DateOnly CreatedAt { get; init; }
}

var book = new Product("book", "9781473217386")
{
    Title = "Neuromancer",
    Price = 7.32
};

// Column-based storage
var repo = TableRepository.Create<Product>(
    CloudStorageAccount.DevelopmentStorageAccount,
    tableName: "Products",
    partitionKey: p => p.Category,
    rowKey: p => p.Id);

await repo.PutAsync(book);

// Document-based storage
var docs = DocumentRepository.Create<Product>(
    CloudStorageAccount.DevelopmentStorageAccount,
    tableName: "Documents",
    partitionKey: p => p.Category,
    rowKey: p => p.Id
    serializer: [SERIALIZER]);

await docs.PutAsync(book);

如果没有提供，序列化程序默认为基于System.Text.Json的DocumentSerializer.Default。

存储中的差异可以在以下Azure Storage Explorer的屏幕截图中看到

在文档表中持久化的 类型 列是持久化实体的 Type.FullName，而 版本 是其程序集的 [主版本号].[次版本号]，这可以用于高级数据迁移场景。主版本号和次版本号组件也作为单独的列提供，以便更容易地通过各种版本范围进行查询，使用 IDocumentRepository.EnumerateAsync(predicate)。

赞助商

了解更多关于GitHub赞助商的信息