我正在尝试编写一个函数，它从S3中拉出一个CSV，并将这些项批量写入DynamoDB。DynamoDB在每个批处理中限制为25个，所以我需要边走边写条目。我遇到的问题是，我用来执行数据库写操作的await函数只在.end()触发，而不是在我检查时触发。谢谢。
浏览 5提问于2020-02-28得票数 1
回答已采纳
1回答
我的应用程序从DynamoDB读取数据，它有一个预先配置的读取容量，这限制了读取吞吐量。我想控制我的查询不会达到限制，下面是我现在是如何做到的： const consumed= await getConsumedReadCapacity() await sleep((con
浏览 0提问于2017-07-31得票数 1
1回答
有没有可能像MongoDB批量写入那样在DynamoDB中批量更新项目？我在MongoDB中有这个函数，希望在DynamoDB中做类似的事情： model: any | null, filterKeys}, if (operations.length % 500 === 0 || i ===
浏览 2提问于2020-08-11得票数 2
CSVStream传递给parseCSV函数，CSVStream是从GetObjectCommand aws/Client-S3接收的流。ParseCSV函数逐行读取CSV行，调用DynamoDB并获取属性，将新属性添加到数据对象，并将数据推送到结果数组。此外，在终端中，首先打印数组，然后打印控制台语句。即使在使用了aysnc之后，我也无法理解，等待我为什么会遇到它。reject) => {
浏览 2提问于2022-10-26得票数 0
在Windows8.1上，这款应用运行良好--一切正常。在Windows phone8.1上，我成功调用了一些ReadAsync(...)NotSupportedException。我以这种方式打开流： { return null; }
浏览 2提问于2015-06-23得票数 1
我正在开发一个批量上传的功能，我来了这个问题。 我想归档文件，这些文件将被上传到我的服务器上。此外，归档文件还将包含一个清单文件-该文件将描述具有各种属性/元数据/等的每个文件。正在读取清单文件的流已关闭，这会导致立即执行回调。下面我将展示示例。const csv = require("fast-csv");const path = require("path");
<e
浏览 13提问于2021-01-20得票数 0
回答已采纳
我正在阅读和，我找不到一个地方说明拥有DynamoDb流是否消耗了流表中的读取容量。
我知道流有自己的容量单位(见我发布的第一个链接)，但我也想知道在启用流之后是否应该增加表的读取容量。
浏览 1提问于2018-11-21得票数 2
回答已采纳
1回答
/ElasticCache views --+我们已经使用了3种数据存储: ElasticCache、DynamoDB和S3 (与雅典娜一起查询)。只有最后一个小时的结果应该通过低延迟随机读取的服务层来查询。
我们的数据库都不符合批量插入和随机读取的要求。DynamoDB不适合批处理-插入-它太昂贵了，因为批量插入所需的吞吐量。流层使用ElasticCache，不确定在那里执行批处理插入是否好。
浏览 1提问于2018-10-28得票数 0
当记录被添加或修改到我的表中时，我使用Dynamodb流来做一些记录方面的工作。我还在应用程序中使用Dynamoose模型。Dynamodb流事件将一个事件对象传递给我的node.js lambda处理程序，该处理程序包括对象record.dynamoDb.NewImage和record.dynamoDb.OldImage。/applyEntry';
async function entryStream(even
浏览 0提问于2019-08-22得票数 0
回答已采纳
如果创建了项目，DynamoDB是否可以有条件地保存时间戳？
看起来AWS通过注释提供了这个功能。
浏览 2提问于2018-05-21得票数 2
8回答
DynamoDB有没有批量更新项目的接口？有一个接口可以批量编写新项(BatchWriteItem)并使用UpdateItem更新单个项，但是否可以在一次调用中更新多个项？
浏览 2提问于2016-11-08得票数 52
关于如何使用DynamoDB和S3正确地管理/处理数据，我有一个问题。例如，我有一个DynamoDB表，其中包含一个用户数据列表(姓名、电子邮件、电话号码)。等等)。我还在S3中拥有用户数据的JSON文件。
而且，当我在S3中更新用户数据时，如何更新DynamoDB中的JSON文件？我需要重写或重新上传一个新的JSON文件到S3吗？
浏览 1提问于2021-06-30得票数 1
回答已采纳
1回答
我正在编写一个lambda函数，它是一个DynamoDB流的接收者。这个被调用的lambda应该创建一个dynamodb表，并启用流并附加一个lambda触发器。这是我的密码- for (const record of event.Records) { StreamViewType: 'NEW_IMAGE&
浏览 8提问于2022-10-26得票数 0
我喜欢dynamodb的一点是，它在AWS上几乎是无限可伸缩的，这是我将要使用的服务，而且速度很快。我正在考虑的一个解决方案是只在mysql中存储坐标，并在dynamodb中存储相应的id以及其他数据(包括lat和long值)。有了这个功能，我就可以实现我想要的地理空间查询功能，同时能够很好地在amazon上扩展所有内容，特别是因为这是我正在使用的主机。因此，基本上，我会从mysql查询给定半径内的
浏览 2提问于2017-01-14得票数 1
当csv文件上传到我的s3存储桶时，我的lambda会被触发将我的数据插入到DynamoDB中。我需要一个流，因为文件太大，无法作为完整对象下载。const batchWrite = async (clientDynamoDB, itemsToProcess) => { ri[TABLE_DYNAMO] = itemsToProcess.map((itm) => toPutRequest(itm));
const params = { Re
浏览 20提问于2020-09-23得票数 0
回答已采纳
我想确定如何限制作业中内存的使用，该作业从本地数据库检索blob并通过块将其传输到第三方web服务。使用SqlDataReader，我似乎有两个选项：
创建一个使用带有偏移量的GetBytes的方法来检索返回byte[]的blob的一部分。创建一个使用GetStream并向ReadAsync发出多个请求以填充byte[]缓冲区的方法，使用该缓冲区发出一个web请求，直到文档被传输为止。我对选项1有偏好，因为它限制了方法的责任，但是如果我用偏移量调用GetBytes，它是将整个偏移量加
浏览 1提问于2019-08-09得票数 2
回答已采纳
从文档中可以清楚地看到，当以TRIM_HORIZON作为迭代器类型启动KCL应用程序时，记录将从流的开头读取。文档还提到，应用程序的状态是通过使用检查点在DynamoDB表中维护的。但是，我没有找到任何参考，KCL应用程序是如何使用这些DynamoDB表信息的。
具体而言，我的问题如下-我有流与168小时的保留期，这是大量的数据。假设我的KCL(从TRIM_HORIZON上的迭代器开始)与传入的数据同步，并且
浏览 5提问于2017-04-01得票数 3
回答已采纳
我试图通过通过DynamoDB流检索dynamodb中的最后一分钟的更改。我认为通过使用ShardIteratorType作为“最新”来实现它。每次使用我得到的Iterator调用getRecords()时，它都返回空记录，而将ShardIteratorType更改为"TRIM_HORIZON“则返回该碎片中的对象。 else resolve(data);
浏览 0提问于2018-09-25得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
