0

在部署 Flink Stateful Functions 时,需要指定函数的端点是什么,即 Flink 需要点击什么 URL 才能触发远程函数的执行。

文档状态:

URL 模板名称可能包含模板参数,这些参数是根据函数的特定类型填写的。例如,发送到消息类型 com.example/greeter 的消息将被发送到 http://bar.foo.com/greeter

endpoints:
  - endpoint:
    meta: 
      kind: http
    spec:
      functions: com.example/*
      urlPathTemplate: https://bar.foo.com/{function.name}

支持哪些其他模板值urlPathTemplate?这些值来自哪里?

4

1 回答 1

1

目前唯一支持的模板值是函数名。即最后一个正斜杠之后的最后一个值/。您可以将其放置在模板中的任何位置,只要它最终会解析为合法的 url。

例如,这也是一个有效的模板:

http://{function.name}.prod.svc.example.com

然后,com.example/greeter(在您的示例中,使用我的新模板)的消息地址将解析为:

http://greeter.prod.svc.example.com

如果您缺少任何其他模板参数,请随时通过用户邮件列表/JIRA 与 Flink 社区联系。我相信他们会很乐意了解新的用例;-)

于 2021-11-03T23:06:06.213 回答