read-write-kinesis-stream:一个使用python lambdas读写AWS kinesis流的小例子

读写写流 一个使用python lambdas读写AWS kinesis流的小例子 为此，我们需要三件事： 运动学流 将数据写入流的lambda Lambda从流中读取数据 您可以从aws命令行创建kinesis流，但是出于本演示的目的，我选择从aws控制台创建流。 因为这只是一个很小的演示，所以我选择仅使用一个分片进行设置。 在运动流中，您可以将碎片视为处理潜力的单位。 流中的分片越多，它可以读取和写入的数据就越多，并且处理它的速度也就越快。 创建流之后，只需创建两个python lambda即可读取和写入它。 这两个lambda都很短，我已经发表了很多评论，因此在这里不再赘述。 一个稍微不寻常的功能是，lambda都不会被事件触发-尽管它们可以并且通常会被触发。 它们是独立的，可以在需要时手动运行，或者更有可能作为AWS Step函数流程的一部分运行（请参阅有关使用step函数的