#python #amazon-web-services #amazon-s3 #pyspark
#python #amazon-веб-сервисы #amazon-s3 #pyspark
Вопрос:
У меня есть лямбда-функция, которая запускается, когда объект попадает в определенную папку в корзине s3 и перемещается в другую папку в той же корзине s3.
Но я пытаюсь изменить лямбда-функцию, в которой лямбда-функция срабатывает только в том случае, если мы получаем все обязательные файлы.(Существующая лямбда-функция, которую я использую, не ожидает других файлов, запускается и перемещается всякий раз, когда загружается новый файл).
Кто-нибудь может мне помочь с этим.
Ответ №1:
Триггеры не функционируют таким образом. S3 запускает лямбда-функцию для каждого загружаемого файла, которая соответствует определению триггера, поскольку она оценивается при каждой загрузке.
Если это проблема с синхронизацией, вы можете использовать функции остановки. S3 запустил бы лямбда-функцию. Lambda запускает пошаговую функцию, которая может ждать X секунд / минут / дней. Затем пошаговые функции запускают другой триггер для выполнения операций в корзине S3.
https://aws.amazon.com/getting-started/tutorials/create-a-serverless-workflow-step-functions-lambda/?amp;trk=el_a131L000005unTnQAIamp;trkCampaign=pac_q2-04-2019_stepfunctions_tutorial_offering_link_2amp;sc_channel=elamp;sc_campaign=pac_q2-04-2019_stepfunctions_tutorialamp;sc_outcome=PaaS_Digital_Marketingamp;sc_geo=mult