我有一个使用 Kinesis 数据分析来处理和聚合实时数据的用例。
是否可以直接从 Appsync 将数据发布到 kinesis 流（无需中间 lambda）？
还要从 kinesis 流触发订阅？
可以使用 appsync 中的 HTTP 数据源发布到 kinesis。以下是有关如何通过身份验证为内部 aws 服务进行设置的参考：https://docs.aws.amazon.com/appsync/latest/devguide/tutorial-http-resolvers-js.html#invoking-aws-services -js
如果没有一些中间步骤，就没有办法将消息从 kinesis 获取到 appsync 中。中间步骤（我将使用 lambda）需要监听 kinesis 流，然后将有效负载作为突变发送到 appsync api。