以下是一个使用AWS Python Lambda函数读取CSV文件的代码示例:
import csv
import boto3
def lambda_handler(event, context):
# 从S3获取CSV文件
s3 = boto3.client('s3')
response = s3.get_object(Bucket='your_bucket_name', Key='your_file_name.csv')
csv_data = response['Body'].read().decode('utf-8').splitlines()
# 使用迭代器逐行读取CSV文件
csv_reader = csv.reader(csv_data)
for row in csv_reader:
# 在这里处理每一行数据
# 例如,打印每一行的内容
print(row)
return {
'statusCode': 200,
'body': 'CSV file processed successfully'
}
在上述示例中,我们首先使用AWS SDK(Boto3)从S3存储桶中获取CSV文件。然后,我们使用csv.reader
将CSV数据作为迭代器逐行读取。在每次迭代中,我们可以对每一行的数据进行处理,例如打印或进行其他操作。最后,我们返回一个包含状态码和响应消息的字典。
请注意,在示例中,你需要替换your_bucket_name
和your_file_name.csv
为实际的S3存储桶名称和CSV文件名称。