amazon-kinesis 相关问题

Kinesis Firehose-S3备份-不起作用-数据未移到s3备份文件夹中

将运动Firehose的“传递流”数据转换为Lambda进行转换并将数据移至两个不同的位置转换/过滤器 -备份s3位置。 -s3位置-我是...

我们可以使用Kafka使用者直接从AWS Kinesis Stream读取吗？

Kafka使用者是否可以直接从AWS Kinesis Stream读取信息？ Azure EventHub提供启用Kafka的选项，以便Kafka使用者可以从EventHub无缝读取。是...

使用StreamConsumer通过Cloudformation将Kinesis Stream连接到DynamoDb的问题

使用cloudformation，我想将Kinesis Stream直接连接到DynamoDB表。看起来方法是使用StreamConsumer。下面的cloudformation脚本给了我这个错误：...

[执行aws cloudformation模板时出错，抛出错误ROLLBACK_COMPLETE

AWSTemplateFormatVersion：'2010-09-09'转换：AWS :: Serverless-2016-10-31说明：“用于为AWS设置Kinesis流，Lambda函数，S3存储桶，DynamoDB表和相关IAM角色的模板...

AWS Lambda和Kinesis客户端库（KCL）

为什么我发现与AWS Lambda一起使用KCL的例子很少。 https://docs.aws.amazon.com/streams/latest/dev/developing-consumers-with-kcl.html它确实提供了很好的实现...

使用Javascript SDK时如何在Amazon Kinesis使用者中获取最新记录？

我正在使用AWS Javascript SDK从Kinesis Data Stream消费。我想获取碎片中的最新记录。当我将ShardIterator Type设置为“ LATEST”时，我没有得到任何记录。 ...

使用bash，jq，sed解析运动学数据

我希望使用bash浏览一些运动数据。使用如下cmd：aws kinesis get-records --shard-iterator | jq'[。| .Records []。Data]'| grep \“ ey | sed -e's / ^ [\ t] * \” ...

aws中是否有任何api可以通过邮递员获取自定义事件数据？

我正在从AWS精确定位设置分析，并且无法通过任何api获取自定义事件数据。我知道获取数据的唯一方法是通过aws kinesis流，该流只能存储多达168个数据...

使用Amazon Rekognition和Kinesis设置人脸检测和识别的问题

我正在尝试对具有亚马逊识别和运动学功能的面部进行检测和识别。我正在使用位于本地网络上的网络摄像机根据AWS文档，我已经完成了...

运动数据流不是实时的？

有一个在kinesis流消息上触发的函数（serverless.yml）：函数：kinesis-handler：处理程序：kinesis-handler.handle事件：-流：类型：kinesis ...

从NuGet包AWS凭证在C＃

我建立一个NuGet包，这将是能够把数据装进AWS室壁运动蒸汽。我不想让NuGet包本身包含任何凭据。我想NuGet包使用的钥匙，...

星火流调度的最佳实践

我们有运行，每30分钟，并采取15秒完成作业的火花流作业。什么是建议在此情况下的最佳实践。我想我可以安排AWS datapipeline运行...

AWS CloudWatch的LogGroup从未发送日志与λ尽管SubscriptionFilter

目的：建立Cloudformation堆栈，需要一个日志组名作为参数，每当新的日志，这些日志日志组中露面，他们会发送到lambda函数进行处理，然后室壁运动...

java.lang.IllegalStateException：连接池关闭从春集成-AWS库例外

我们正在使用弹簧集成-AWS-2.0.0连接到室壁运动来听流。虽然停止应用程序，总是收到以下异常。 a.i.k ....

调用PutSubscriptionFilter操作时发生错误（InvalidParameterException）

[试图将云监视日志放入kineses firehose。如下所示：https://docs.aws.amazon.com/AmazonCloudWatch/latest/logs/SubscriptionFilters.html#FirehoseExample得到此错误错误...

室壁运动代理蟒蛇流数据报告错误

想从一个Python代码创建一个简单的流数据，被附加到一个日志文件，并且使用室壁运动代理 - >室壁运动流水流数据加载到一个红移群集。我可以证实，...

在单个Java进程中处理多个Kinesis流

我想在同一个Java进程中使用KCL处理多个Kinesis流。这个想法很简单：为每个流创建一个新的KCL实例，然后同时运行这些工作程序。我......

是否可以按需阅读Kinesis流而没有延迟

我有以下用例我有kinesis流有用户数据。我想根据用户操作阅读kinesis流。根据用户输入过滤记录，保持过滤一段时间，让...

是否有AWS Kinesis Firehose的Kafka对应物？

看起来像AWS Kinesis Firehose是一种将数据（缓冲在一起）摄取到一个对象的方法，这种功能是否有Kafka对应物？

通过JdbcLockRegistry自动缩放组中的Spring Cloud Stream Kinesis Group

我正在尝试创建一个使用Spring云流来消耗来自Kinesis流的事件的消费者应用程序。我的消费者应用程序在AWS自动缩放组中运行，我会......