Я пытаюсь реализовать рабочий процесс прочной функции Azure. < /p>
Иногда, однако, функция оркестровки называется дважды в течение нескольких секунд! Это большая проблема, так как мои функции активности не являются идентифицирующими![FunctionName("StartupFunc")]
public static async Task Run([TimerTrigger("0 */6 * * * *", RunOnStartup = true, UseMonitor = false)]TimerInfo myStartTimer, [OrchestrationClient] DurableOrchestrationClient orchestrationClient, TraceWriter log)
{
List ExportModels = await getData();
string id = await orchestrationClient.StartNewAsync("OrchestratorFunc", ExportModels);
}
< /code>
Функция оркестровки: < /p>
[FunctionName("OrchestratorFunc")]
public static async Task TransformOrchestration([OrchestrationTrigger] DurableOrchestrationContext context, TraceWriter log)
{
var dataList = context.GetInput();
var tasks = new List();
foreach (var data in dataList)
{
tasks.Add(context.CallActivityAsync("TransformToSql", new TransformModel(data));
}
await Task.WhenAll(tasks);
}
< /code>
Функция активности: < /p>
[FunctionName("TransformToSql")]
[public static async Task RunTransformation([ActivityTrigger] DurableActivityContext context, TraceWriter log)
{
TransformModel = context.GetInput();
//Do some work with TransformModel
}
Подробнее здесь: https://stackoverflow.com/questions/522 ... ring-twice
