python - 通过 Http 触发器将新的输入数据发送到已经运行的 Orchestrator 功能

Question

我目前正在构建一个通过 Http 触发器触发的 Azure 持久功能。当向 Http 触发器发送初始请求时，我包含了一个 API token ，然后该 token 作为输入传递给 Orchestrator，Orchestrator 又将该 token 传递给事件。现在我注意到这个 token 有时会在 Orchestrator 完成之前过期，从而产生身份验证问题。

我已经每隔几分钟轮询一次初始 Http 触发器，并使用 DurableOrchestrationClient.get_status() 方法检索 Orchestrator 的状态，因此我想知道是否可以以某种方式将新 token 传递给每次我进行此类轮询时，都会通过 Http 触发器运行 Orchestrator。这将解决我的身份验证问题。

查看文档似乎没有简单地传递新输入的功能，到目前为止我发现的只是创建可以发送到正在运行的编排器的外部事件的选项。详细信息请参阅此链接:https://learn.microsoft.com/en-us/azure/azure-functions/durable/durable-functions-instance-management?tabs=python#send-events-to-instances

这是我解决这个问题的最佳选择吗？

Answer 1

我会避免依赖外部方传递新 token ，Orchestrator 不应依赖此类调用才能成功完成。

假设您使用 Azure Active Directory 或类似系统，我的建议是使用 On Behalf Flow 。您将向您的 Orchestrator 发送一个初始 API token ，同时验证对 Orchestrator 的调用。然后，您使用此 token 为下游服务获取新 token 。这样，您还将收到刷新 token ，可用于获取新的访问 token 。

如果您不想/不需要使用初始 API token 对 Orchestrator 调用进行身份验证，您还可以按照 cetver 在评论中的建议传入刷新 token 。

在此示例中:“Web API A”将是您的 Orchestrator: