问题标签 [apache-camel-aws-kinesis]

我正在使用 lambda，它使用运动流作为触发器。下面是触发器的配置

在几个小时内启用 kinesis 触发器后，我从 lambda 收到错误消息，显示为“最后处理结果：问题：内部 Lambda 错误”。

仅供参考，我的 lambda 处理逻辑：

Lambda 从 Kinesis 获取数据

执行少量转换

将数据推送到 power bi

几周以来我一直在遭受这个问题的困扰，任何帮助都非常感谢

我们如何将 pojo 变量作为 json 生成到 kinesis flink 流中：

这里transformedStream被下沉到另一个kinesis但是作为json但是如何转换为json

我需要通过 http 从 lambda 返回大量数据。对大量数据的查询速度很慢，很容易超过 30s 的限制。引入分页不是一种选择，但可以作为一个长而缓慢的请求。它需要是一个简单的GET端点。这些要求是由第三方强加的。

是否可以返回某种类型的流，例如 s3 流或 kinesis 流？

我正在玩 kinesis，我尝试了非常简单的示例。我已经执行的步骤：执行生产者来放置一些成功的记录。

执行 getRecords 时在消费者端面临错误。我试图更改所有这些方法以从 api 获取记录：'AT_SEQUENCE_NUMBER | AFTER_SEQUENCE_NUMBER | TRIM_HORIZON | 最新的'。

回复：

( [数据:Aws\Result:private] => 数组 ( [记录] => 数组 ( )

源代码：

我也浏览了 AWS 文档，发现我们发送的所有详细信息都是正确的，但我们仍然没有收到任何回复记录。

谢谢

我正在尝试将事件数据从 kinesis 流式传输到 pinpoint。但是当我点击选择图片上的亚马逊运动流时，我无法看到我创建的传输流。请有人可以帮助我，我厌倦了找到解决方案。