使用Boto3 S3和Lambda自动创建CSV文件

Question

我正在LinuxAcademy网站上做一个实验室。com课程名称是使用Lambda、Python和Boto3自动化自动气象站，我遇到问题的具体实验室是讲座：将CSV文件导入DynamoDB。

在这个实验室中，我们将一个. csv文件上传到S3，在该特定桶中生成一个S3事件，然后启动如下所示的Lambda脚本：

import csv
import os
import tempfile

import boto3

dynamodb = boto3.resource('dynamodb')
table = dynamodb.Table('Movies')
s3 = boto3.client('s3')


def lambda_handler(event, context):

    for record in event['Records']:
        source_bucket = record['s3']['bucket']['name']
        key = record['s3']['object']['key']
        with tempfile.TemporaryDirectory() as tmpdir:
            download_path = os.path.join(tmpdir, key)
            s3.download_file(source_bucket, key, download_path)
            items = read_csv(download_file)

            with table.batch_writer() as batch:
                for item in items:
                    batch.put_item(Item=item)


def read_csv(file):
    items=[]
    with open(file) as csvfile:
        reader = csv.DictReader(csvfile)
        for row in reader:
            data = {}
            data['Meta'] = {}
            data['Year'] = int(row['Year'])
            data['Title'] = row['Title'] or none
            data['Meta']['Length'] = int(row['Length'] or 0)
            #data['Meta']['Length'] = int(row['Length'] or 0)
            data['Meta']['Subject'] = row['Subject'] or None
            data['Meta']['Actor'] = row['Actor'] or None
            data['Meta']['Actress'] = row['Actress'] or None
            data['Meta']['Director'] = row['Director'] or None
            data['Meta']['Popularity'] = row['Popularity'] or None
            data['Meta']['Awards'] = row['Awards'] == 'Yes'
            data['Meta']['Image'] = row['Image'] or None
            data['Meta'] = {k: v for k,
                            v in data['Meta'].items() if v is not None}

上传到s3的.csv文件确实调用了lambda函数。第20行出现错误：items=read\u csv（download\u file）

AWS CloudWatch出错：

[ERROR] NameError: name 'download_file' is not defined
Traceback (most recent call last):
  File "/var/task/lambda_function.py", line 20, in lambda_handler
    items = read_csv(download_file)

Answer 1

s3.download_file(source_bucket, key, download_path)
items = read_csv(download_file)

第一行调用Amazon S3客户端上的下载文件（）方法，将文件下载到本地磁盘。

第二行调用read\u csv（）函数，传递一个名为download\u file的变量。但是，尚未定义名为下载文件的变量，这就是您收到错误的原因。

在查看代码时，read_csv（）函数期望打开文件名。这似乎在download_path变量中可用，其中包含本地目录和密钥。因此，将其更改为：

items = read_csv(download_path)