azure-durable-functions相关内容
我正在尝试创建延迟x秒的持久函数。不幸的是,x越大,误差就越大。 我使用的是MS docs中显示的示例: unction.json: { "bindings": [ { "name": "context", "type": "orchestrationTrigger", "direction": "in" } ],
..
在我的活动功能中,我正在执行此操作 do { await timeout(500); } while (await getStatus() === false); Where, function timeout(ms) { return new Promise(resolve => setTimeout(resolve, ms)); } getStatus
..
我是新来的Azure。我想创建一个返回序列号的函数。我已经使用线程互斥锁创建了一个函数来锁定序列号。我用大约10k个并行请求测试了下面的代码。问题是我在做测试时得到了重复的序列号,互斥体不工作。我不确定如何避免重复,而是为每个请求生成流水号 Public class MySharedMutexCounter { public static long count = 0; publ
..
我有一个现有的具有 2 个函数和一个存储队列的函数应用程序.F1 由服务总线主题中的消息触发.对于收到的每个消息,F1 计算一些必须以不同延迟量执行的子任务(T1,T2,...).Ex - T1 在 3 分钟后触发,T2 在 5 分钟后触发,等等.F1 将消息发布到具有适当可见性超时(以模拟延迟)的存储队列,并且只要队列中的消息可见,就会触发 F2.一切正常. 我现在想迁移此应用以使用“持久
..
我创建了一个基于 Visual Studio 的标准持久函数“添加新函数"到项目中.这开箱即用. 然后我按照这里的步骤操作:https://docs.microsoft.com/en-us/azure/azure-functions/functions-dotnet-dependency-injection 添加依赖注入.添加 Microsoft.Extensions.http. 这破
..
我们在blob存储中创建了许多文件,因此,我们将这些文件传递给了azure函数.但是,如果使用Azure功能和事件网格触发器,则在确定为否之后会超时.的文件已处理.因此,现在我正在尝试使用持久功能. 下面是我尝试的代码. ProcessJob_EventGrid被触发.但是,ProcessJob_Orchestrator永远不会被触发.有什么我想念的吗? 我对“持久功能"概念完全
..
我可以看到azure持久功能使用存储帐户来管理状态和检测.在具有大量数据表和队列的环境中运行持久功能时,将变得越来越大,并且相应地速度也会越来越慢.持久功能是否可以自我记录日志,还是您需要自己完成这项任务? 解决方案 研究此问题之后,似乎应该由开发人员来实现自己的处理程序.我通读了github问题,并发布了可接受的答案,并且看起来函数团队仅实现了API所需的这是官方文档中的示例-只是添加了
..
我们正在使用一个持久的Orchestrator函数,该函数需要对Activity函数进行数百万次调用.100,000次调用后,我们看到以下异常: 已达到最大编排操作100,000.这值可以在host.json文件中配置为MaxOrchestrationActions. 但是,我找不到如何设置此值. 在此处为host.json模式,未指定. 我为 Azure功能持久扩展的开发
..
因此,我在持久性函数中意识到,当调用活动函数时,当前的持久性函数实际上会停止并等待重新开始.我的问题是原始持久功能如何退出?我已经进行了一些调试,并且没有引发异常,也没有返回任何值.它如何退出? [FunctionName("DurableFunction"))公共静态异步任务持久([OrchestrationTrigger] IDurableOrchestrationContext上下文,I
..
我正在发布此问题,以查看我是否正确理解了Azure Functions(尤其是持久函数)中的并行性. 最近使用az cli将设置最大并行度的功能添加到Azure Functions中: https://github.com/Azure/azure-functions-host/issues/1207 az资源更新-资源类型Microsoft.Web/sites -g
..
问题 我有一个包含编排和活动功能的C#耐用Azure函数应用(v2). 业务流程按如下方式调用活动: propBag.CE = await context.CallActivityAsync(nameof(GetCEByExternalIdActivity), propBag); 调用正常,执行Activity函数,构建propBag.CE的内容并返回. CE
..
我是“领域驱动设计”的忠实拥护者和开发人员,并且一直试图将技术/体系结构映射到DDD领域。将微服务映射到有限的上下文提供了自然的结合。归根结底,我只想专注于业务逻辑并将其托管在正确的环境中。持久功能对我来说很有希望,因为如果需要的话,它需要解决跨微服务,Sagas或Process Manager的分布式事务问题。我已经使用NServicebus多年了,并且喜欢他们的Saga技术,但是想利用Dura
..
看来我不能拥有使用Blob绑定的活动功能.下面给出了运行时错误: [StorageAccount("AzureWebJobsStorage")] [FunctionName("LoadBlobFromBlobStorage")] public static async Task Run([ActivityTrigger] string blobName, [Blob("con
..
我有一个需要计算50万活动的场景.所有小的计算.由于节流,我只能同时计算30. 想象下面的简单示例: [FunctionName("Crawl")] public static async Task> RunOrchestrator( [OrchestrationTrigger] DurableOrchestrationContext context)
..
我有一个持久功能,该功能每天由计时器触发器触发一次: [FunctionName("MyDurableFunction")] public static async Task Run( [TimerTrigger("0 0 23 * * *", RunOnStartup = false)] TimerInfo myTimer, [OrchestrationClient] Du
..
我使用了带有自定义dll(.net核心2.2)的v2 azure函数(持久函数),该函数调用服务,但出现以下异常: 无法加载文件或程序集'System.Private.ServiceModel, 版本= 4.1.2.4,文化=中性,PublicKeyToken = b03f5f7f11d50a3a' 在调试过程中,我无法进入该方法,并且在不让我进入该方法的情况下引发了异常,并且我不知道
..
我有一个具有2个功能和一个存储队列的现有功能应用程序. F1由服务总线主题中的消息触发.对于收到的每个味精,F1计算一些子任务(T1,T2,...),这些子任务必须以不同的延迟量执行.例如-T1将在3分钟后触发,T2将在5分钟后触发,等等.F1将消息发布到具有适当可见性超时(以模拟延迟)的存储队列中,并且每当消息在队列中可见时就会触发F2.一切正常. 我现在想将该应用程序迁移为使用“耐用功能
..
我试图在我们的持久功能项目中查找一些偶然的Non-Deterministic workflow detected: TaskScheduledEvent: 0 TaskScheduled ...错误.它很少见(在10,000左右的实例中为3次). 在将协调器代码与约束进行比较时类似于以下简化示例的东西: [FunctionName(Name)] public static async
..
我正在尝试使用持久功能进行一些数据转换.为此,我有一个TimerTriggered函数,该函数调用Orchestration函数,然后产生转换活动. 我的问题是,在Orchestration函数被调用时,它立即产生了很多活动,甚至没有到达启动该函数的代码部分.我的编排功能只能启动3个活动,因为我的dataList仅包含3个元素. 但是可以看到,在下面包含的日志输出中,在调用了编排函数之
..
我从Visual Studio“添加新功能”创建了一个标准的持久功能到项目。 然后我按照此处的步骤操作:”> https://docs.microsoft.com/zh-cn/azure/azure-functions/functions-dotnet-dependency-injection 添加依赖项注入。添加Microsoft.Extensions.http。 这会破坏功能,并且
..