【发布时间】:2022-01-07 06:14:24
【问题描述】:
我想每分钟运行一个简单的 .net 6 c# 消费 azure function app(不持久),但我需要记住上次运行的状态。
状态由 json 可序列化对象数组和一些访问令牌字符串组成。
所以我创建了一个这样的持久函数实体:
[JsonObject(MemberSerialization.OptIn)]
public class DurableStorageEntity
{
[JsonProperty("simpledata")]
public string SimpleData { get; set; }
[JsonProperty("complicateddata")]
public List<ComplicatedObject> ComplicatedData { get; set; }
public void SetSimpleData(string data) => this.SimpleData = data;
public void SetComplicatedObject(List<ComplicatedObject> data) => this.ComplicatedObject = data;
[FunctionName(nameof(DurableStorageEntity))]
public static Task Run([EntityTrigger] IDurableEntityContext ctx)
=> ctx.DispatchAsync<DurableStorageEntity>();
}
这很好用,但我不确定它的效率如何,以及我可以通过这种方式存储多少状态数据。经过测试,我也不确定从常规(即非持久)函数应用调用时这是否可靠。
我找不到任何明确的信息。在MS document on Entity Functions 中,它只是声明:
实体函数定义用于读取和更新小块状态的操作,称为持久实体。
和
实体提供了一种扩展应用程序的方法,方法是将工作分布在许多实体中,每个实体都具有适度大小的状态。
所以这让我不确定我可以存储多少数据。我通常会存储几个数组,每个数组有几百个项目,每个对象由字符串、整数和日期组成。如果有更好的方法在运行之间存储状态,那么欢迎使用替代方法,但我确实喜欢使用这些实体函数,所以我希望它是一个可行且可靠的选择。
12 月 2 日更新:
我一直在测试使用 100 项对象数组(字符串、整数、日期时间)存储对象列表。
我在我的机器上本地运行它。我可能做错了什么,但偶尔它会返回我之前存储的旧数据,而不是持久实体存储中存储的最新数据。我不确定为什么会这样。我可以通过存储大量数据来实现它,但它也可以在其他时间随机发生。
生成 100 个对象 大小:6 365 853 字节 读取时间:250ms 写入时间:215ms
生成 1000 个对象 大小:63 658 851 字节 读取时间:2s 659ms 写入时间:1s 811ms
生成 10000 个对象 写入似乎成功,但读取时获得了之前的 1000 个对象
生成 10 个对象 按预期回读 10 个对象
生成 2000 个对象 错误:仍然得到 10 个对象
生成 1000 个对象 错误:仍然得到 10 个对象
生成 100 个对象 错误:仍然得到 10 个对象
生成 1 个对象 终于按预期取回了 1 个对象
生成 10 个对象 错误:三次运行仍获得 1 个对象,但在函数应用程序的第四次运行时突然获得 10 个对象。
这是在我的本地机器上,win10、i7、32Gb RAM,并且在 VS2022 中没有调试器。
【问题讨论】:
标签: c# azure .net-core azure-functions azure-durable-functions