Time-triggered lambda कोड
Cody चाहती हैं कि सभी स्पीड लिमिट तोड़ने वालों की पूरी रिपोर्ट कभी भी, हमेशा के लिए उपलब्ध रहे — और वह हर रात अपडेट हो.
उन्होंने आपसे एक नाइटली जॉब बनाने के लिए कहा है.
वर्तमान स्ट्रक्चर इस तरह दिखता है:
पिछले अभ्यास में जो फंक्शन आपने बनाया था, उसके lambda_handler मेथड में जाने वाला कोड लिखिए.
सभी boto3, pandas और awsrangler आपके लिए इम्पोर्ट कर दिए गए हैं, और keys पहले से परिभाषित हैं.
चलिए शुरू करें!
यह अभ्यास पाठ्यक्रम का हिस्सा है
AWS Kinesis और Lambda के साथ स्ट्रीमिंग डेटा
अभ्यास निर्देश
AWS_KEY_IDऔरAWS_SECRETके साथ boto3 सत्र इनिशियलाइज़ करें.- सभी speeder डेटाफ़्रेम पाने के लिए सत्र को AWS Wrangler के
read_csvमेथड में पास करें. - प्राप्त csv को key
"sd-vehicle-data/speeders-full/full.csv"के साथ AWS Wrangler से लिखें.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
# Initialize boto3 session
session = boto3.____(aws_access_key_id = AWS_KEY_ID,
aws_secret_access_key = AWS_SECRET,
region_name="us-east-1")
# Read all records in the speeders folder
speeders_total = wr.s3.____('s3://sd-vehicle-data/speeders',
____ = session,
delimiter=" ")
# Write aggregated speeders file
____.____.to_csv(df = speeders_total,
boto3_session=session,
path="____://sd-vehicle-data/speeders-full/full.csv")