如何将一个lambda转换为另一个lambda



我有一个S3存储桶,里面有多个文件夹。在这个文件夹中将有多个文件。我已经装入了一个lambda,它将在Snowflake中执行一个过程。此过程的主要目标是将S3存储桶中的CSV文件中的值加载到原始数据表中。lambda函数只能工作15分钟。我需要更多。所以我想我可以将数据从s3 bucket加载到每个文件夹的Snowflake。(从一个文件夹加载数据需要11分钟以上(因此,例如,在S3 bucket中,我将有文件夹Test_1、Test_2。在这些文件夹中,我会有文件file_1、file_2等。那么,如何从一个lambda调用另一个lambda,使我只能在每个文件夹中加载数据呢?Lambda的数量将与文件夹的数量相同。所以它可以每天改变

您可以使用SNS来触发相同或另一个Lambda函数。第一个Lambda函数可以发布具有通知消息中的上下文/状态信息的SNS通知。第二个Lambda函数可以是相同的Lambda,可以订阅SNS主题。

如果第二个Lambda与第一个Lambda相同,则必须确保永远不会出现无限递归调用的情况。

最新更新