将dynamodb流拆分为多个碎片所需的写入活动？
我正在以每秒350次的速度向DynamoDB表写入数据。我已经在其上启用了流，并配置了多个消费者来读取每个碎片。每个消费者只能处理100条记录/秒，这意味着我需要至少4个消费者处理流。问题是，当写入数/秒增加时，DynamoDB不会创建多个碎片。想知道DynamoDB在什么时候开始创建多个碎片（写入数/秒的值）
我曾尝试在每秒100到350次写入之间写入表
如何触发多个碎片，从文档中可以看出，没有办法发布API来触发dynamodb流上的碎片/重新碎片
共有1个答案
没有办法做到这一点。分片是根据表分区自动处理的。
作为替代方案，您可以让一个消费者从DynamoDB流中读取记录并将其转发到另一个流，在那里您可以控制碎片的数量。
-
我读过很多关于这方面的文章，但也有2012年或更早的文章。 （我只是打算从数据库中读取和插入一些数据。）
-
我有大约20个活动，扩展了基础活动，反过来扩展了activity。现在，我的要求是将包括BaseActivity在内的所有这些活动转换成片段。任何支持都将不胜感激。下面是我的应用程序的示例代码。
-
我可以使用一个片段作为一个活动吗？我已经创建了一个片段，但我希望它有像活动一样的功能，所以我使用片段扩展碎片活动。然而，我有一个带有碎片的导航抽屉。当我更改为“扩展碎片活动”时，我的代码有问题？请给我指路。
-
我已经读过一些关于动画片和多个消费者的问题，但我仍然不明白它是如何工作的。 我的用例：我有一个只有一个分片的运动流。我想使用不同的lambda函数使用这个分片，每个函数都独立。就像每个lambda函数都有自己的分片迭代器一样。 有可能吗？是否设置多个lambda使用者（基于流）从同一流/碎片读取？
-
我有一个Akka Streams，我想根据谓词将其分成两个源。 例如。有一个源（类型被有意简化）： 还有两种方法： 我希望能够拆分根据谓词，并将右侧部分传递给方法，左侧部分传递给方法。 我尝试使用拆分器，但它需要s结尾。
-
我一直在看谷歌Android架构的MVP与匕首2的例子： https://github.com/googlesamples/android-architecture/blob/todo-mvp-dagger/todoapp/app/src/main/java/com/example/android/architecture/blueprents/todoapp/tasksactivity.java