EKS Fluent-Bit无法从服务帐户中扮演AWS角色
我要为通过EKS中的Helm安装的流利位守护程序而生气。 看起来EKS上没有IAM上的OIDC提供商，但这是错误的！你能帮忙吗？ 流利的位日志： [2022/06/29 15…
使用Python将数据从AWS lambda推到运动式消防方
我正在尝试使用Lambda功能将数据从RDS发送到FireHose。我能够使用lambda函数从RDS检索数据。现在，我想将这些数据从lambda功能发送到Kinesis Firehose…
尝试从Firehose摄取数据时会出现错误
命令中造成错误1206和1205， 下面的原始数据 { "Name": "yoyo" "a_timestamp": "2021-05-11T15:02:02.426729Z", "a_date": "2021-05-11T00:00:00Z" } …
如何使用Python CDK启用了动态分区？
我正在尝试创建一个启用动态分区的消防输送流。 以下是我到目前为止所得到的。 analytics_delivery_stream = kinesisfirehose.CfnDeliveryStream( sel…
AWS Kinesis Firehose通过AWS Lambda发动机
我正在创建一个架构，生产商将数据发送给AWS Kinesis Firehose。我需要通过AWS kinesis将数据存储到DynamoDB中。根据 documentation>目的地。是否可以…
如何定义从Python SDK发送到Firehose的JSON的AWS胶模式？
我考虑了此设置： pythonsdk发送预定义的json-＆gt; AWS Kinesis Firehose-＆GT;使用AWS Glue Schema-＆GT;将数据转换为“镶木”。 是否成功）。 将数…
AWS红移交付的无效价值错误
我正在使用Kinesis Firehose将其传递到RedShift数据库。当Firehose试图从S3存储桶上保存的流中执行复制查询时，我被困。 错误就是 ERROR:Invalid valu…
通过Terraform将lambda功能添加到运动式消防中
我在S3中有一个Firehose递送流数据。但是，在存储之前，我想将lambda功能添加到交付流中以解析数据。 除了为此目的外，我还需要IAM政策吗？…
如何放置映射类型的记录＆lt; string，array＆lt; string＆gt;＆gt;使用Firehose Python SDK胶水
首先，我创建了一个简单的胶水模式和AWS交付流。使用简单类型（例如字符串或浮点），我可以通过使用以下python代码将记录放在交货流中，并看到它转换…
将AWS运动型和运动式消防添加到现有的DynamoDB中
我们正在寻找添加运动型流和运动式消防方，以将数据从我们的DynamoDB操作数据存储迁移到S3。 我创建了Kinesis流和Kinesis Firehose交付流，以将数据发…
如果我正在从运动式数据流中读取FireHose的最大数据摄入率？
文档陈述以下： Kinesis Firehose只能摄入5 MIB/SEC，并且在基本64编码之前，发送给Kinesis Data Firehose的记录的最大大小为1,000 KIB。 有没有办法…
Terraform投掷无效的Exception重复的处理图片仪传递给Kinesis Firehose动态分区的加工configuration
我正在尝试使用Terraform使用TerraForm创建动态式消防，并使用“正在收到的JSON”中的两个分区查询进行动态分区，我的处理配置看起来像这样， process…
CDK2使用现有的KinesisfireHose资源
我正在尝试创建一个运动式消防输送流，而当前的alpha版本（L2构造）不支持格式转换。 （） 我正在尝试使用L2构造创建交付流，然后使用L1构造（CFNDeli…
如何将 OpenSearch/Elasticsearch 设置为 Kinesis Firehose 的目的地？
我正在尝试创建数据流 ->消防水带 ->使用 AWS CDK v2 的 OpenSearch 基础设施。我惊讶地发现，尽管 OpenSearch 是受支持的 Firehose 目标，但 CDK 中…
