我基于“异步 HTTP API”模式中的 Microsoft 示例创建了一个持久函数。
在我的代码流中，我希望在不使用“await contextReq.CallActivityAsync”的情况下更新“SetCustomStatus”。
可能吗？因为我的持久功能保持在“待定”状态，并且“customStatus”没有得到更新。
一些代码片段：
[FunctionName("UpdateItemsWithProgress")]
public static async Task<HttpResponseMessage> HttpStart(
[HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")]HttpRequestMessage req,
[OrchestrationClient]DurableOrchestrationClient starter,
ILogger log)
{
dynamic jsonMessage = await req.Content.ReadAsAsync<object>();
try
{
string contentType = req.Content.Headers?.ContentType?.MediaType;
if (contentType == "application/json")
{
string instanceId = await starter.StartNewAsync("updateTransitItem", jsonMessage);
log.LogInformation($"Started orchestration with ID = '{instanceId}'.");
return starter.CreateCheckStatusResponse(req, instanceId);
} else
{
return starter.CreateCheckStatusResponse(req, null);
}
}
catch (Exception e)
{
return starter.CreateCheckStatusResponse(req, e.Message);
}
}
[FunctionName("updateTransitItem")]
public static async Task<object> RunOrchestrator(
[OrchestrationTrigger] DurableOrchestrationContext contextReq)
{
dynamic dynObj = contextReq.GetInput<object>();
contextReq.SetCustomStatus("Working...");
// doing stuff
contextReq.SetCustomStatus("1");
// doing stuff
contextReq.SetCustomStatus("2");
// doing stuff
return "Success"
}