我怎么能让5个以上的lambda消费相同的运动流？

Question

我希望有一个包含大量Lambda消费者的Kinesis流（不同的Lambda函数，而不仅仅是同一个函数的多个实例）。

Kinesis限制为每秒5次读取事务（docs）。Lambda函数将每秒轮询一个碎片。

这是否意味着，当我向流中添加第六个Lambda消费者时，我的读取应该受到限制？

我知道一个流上超过5个消费者可以使用新的增强扇出功能，但是我找不到任何关于这个新功能的Lambda函数的提及。他们只谈论KCL2。

相反，我发现了一些老文章，其中描述了他们自己的扇出实现，以避免落后于Lambda消费者，例如这篇文章。我想知道这是否仍然需要，或者Lambda消费者也可以利用新的增强扇出。

Answer 1

你能试试这样的吗？

/* in the parent lambda */

var consumers = [
  {
    id: "consumer",
    eventData: someData // stream data inserted here
  }
]

var params = {
  ClientContext: "MyApp", 
  FunctionName: "MyFunction", 
  InvocationType: "Event", 
  LogType: "Tail", 
  Payload:  null,        // <Binary String> 
  Qualifier: "1"
 };

let invoke = () => {
  return new Promise((resolve, reject) => {
    lambda.invoke(params, function(err, data) {
      if (err) reject(err);
      else     resolve(data);
    });
  })
}

invokeArr = []
consumers.map((consumer) => {
  params.Payload = consumer.eventData
  invokeArr.push(invoke)
})

Promise.all(invokeArr).then((data) => console.log('were done'))