Response:
{
"errorMessage": "Unable to import module 'lambda_function': No module named 'pandas'",
"errorType": "Runtime.ImportModuleError"
}
हैंडलर अपडेट करना
#lambda_function.py
import json, boto3, pandas as pd
# Initialize clients
...
SPEED_ALERT_THRESHOLD = 45
ALERT_PHONE_NUMBER = "+1234567890"
# Helper function to get dataframe from written records
def get_new_data(event):
pd.read_csv()...
...
return data
# Lambda function handler
def record_created_handler(event, context):
data = get_new_data(event)
...
sns.publish()
...
get_new_data()
def get_new_data(event):
# Create a list to store new object keys.
written_objects = []
# Iterate over each S3 event record.
for record in event['Records']:
# Get the variables to check for
event_name = record['eventName']
bucket_name = record['s3']['bucket']['name']
obj_key = record['s3']['object']['key']
get_new_data()
def get_new_data(event):
...
# Verify that event is created from sd-vehicle-data bucket.
if event_name == 'ObjectCreated:Put' and bucket_name == 'sd-vehicle-data':
obj = s3.get_object(Bucket=bucket_name, Key = obj_key)
df = pd.read_csv(obj['Body'], delimiter = " ",
names=["record_id", "timestamp", "vin", "lon", "lat", "speed"])
written_objects.append(df)
# Concatenate new records into a single dataframe.
return pd.concat(written_objects)
record_created_handler()
SPEED_ALERT_THRESHOLD = 45
ALERT_PHONE_NUMBER = "+1234567890"
...
def record_created_handler(event, context):
# Call the helper method
data = get_new_data(event)
## Get the top speeds
top_speeds = data.groupby(['vin'])['speed'].max().reset_index()
## Get top speeds that exceed the limit of 45
too_fast = top_speeds.loc[top_speeds.speed > SPEED_ALERT_THRESHOLD, :]
record_created_handler()
SPEED_ALERT_THRESHOLD = 45
ALERT_PHONE_NUMBER = "+1234567890"
...
def record_created_handler(event, context):
...
## Send SMS
sns.publish(PhoneNumber=ALERT_PHONE_NUMBER,
Message="Speeding Alert \n" + too_fast.to_string())
## This doesn't go anywhere yet, but we need to return something.
totals = data.groupby(['vin'])['speed'].max().reset_index()
return totals.to_csv(sep=" ", index=False)
Lambda फंक्शन का टेस्ट करें
Environment variables जोड़ना
import os
os.environ.get("ENV_VARIABLE_NAME", "DEFAULT_VALUE")
Preparing Video For Download...
