किसी ईवेंट के आधार पर S3 से डेटा पढ़ना

पिछले अध्याय के अंत में, आपने S3 से डेटा पढ़ने के लिए एक method लिखा था — analyze_data. हालाँकि, आपको वह method manually चलाना पड़ता था.

अब हम एक Lambda फंक्शन लिखेंगे जो हर बार तब रन होगा जब Firehose S3 में कोई नया फ़ाइल लिखेगा। फिलहाल, यह केवल जोड़े गए फ़ाइलों के नाम प्रिंट करेगा।

आप एडिटर में recordReaderS3/lambda_function.py फ़ाइल को एडिट करेंगे। इसी में हमारे Lambda फंक्शन का handler है।

ध्यान रखें: S3 में कोई ऑब्जेक्ट लिखे जाने पर ObjectCreated:Put ईवेंट आता है। आप ऊपर दाएँ कोने में slides आइकन पर क्लिक करके स्लाइड्स देख सकते हैं — वे काफ़ी मददगार रहेंगी!