来自流分析的 Azure 函数 HTTPTrigger

如何解决来自流分析的 Azure 函数 HTTPTrigger

因此，我配置了一个流分析作业，该作业将来自事件中心的流事件作为输入，执行提取几个字段的查询，然后将结果输出到 Azure 函数中。我创建了一个基于 HTTPTrigger 的函数，因为 SA 作业将发送输出的 HTTP 请求。 __init__.py 文件如下所示。我想在 init 文件中创建一个函数 process_data()，用于执行情绪分析并返回情绪分数。

import azure.functions
    
def main(req: azure.functions.HttpRequest) -> str:
    content = req.params.get('content')
    pos_score,neg_score,neu_score = process_data(content)
    ...

您是否建议我为此创建一个完全独立的函数？或者我可以在与 HTTPTrigger 相同的 Function 文件夹中执行此操作吗？例如，我将如何将函数的输出发送到存储？我必须配置functions.json文件吗？对 Azure 整体来说还是新手，所以我希望我能很好地解释自己。