0

因此,我配置了一个流分析作业,该作业将来自 Event Hub 的流事件作为输入,执行一个提取几个字段的查询,然后将结果输出到 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 来说还是新手,所以我希望我能很好地解释自己。

4

0 回答 0