Amazon Rekognitionを利用した画像解析システムの構築において、DynamoDB と Amazon Elastic Searchのzipファイルを利用した接続が出来ません。

前提・実現したいこと

発生している問題・エラーメッセージ

AWSを利用して表題の件を実現したかったのですが、Lambda関数を用いたDynamoDB と Amazon Elastic Searchのzipファイルを利用した接続が出来ません。

以下のコードをzipファイルとしてLambda関数に用いたのですがzipファイルにすることがどうしもできません。

該当のソースコード

import requests
import json
from aws_requests_auth.aws_auth import AWSRequestsAuth
import random
import string
import datetime
from urlparse import parse_qs

print('Loading function')

def lambda_handler(event, context):
auth = AWSRequestsAuth(
aws_access_key='xxxxxxxxxxxxxxxxxxxx',
aws_secret_access_key='xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx',
aws_host='elastic-search-endpoint',
aws_region='us-east-1',
aws_service='es'
)
for record in event['Records']:
dynamodb = record['dynamodb']
if "NewImage" in dynamodb.keys():
strlabel = (json.dumps(record['dynamodb']['NewImage']['label']['S']))
strconfidence = str((json.dumps(record['dynamodb']['NewImage']['confidence']['N'])))
strimage = str((json.dumps(record['dynamodb']['NewImage']['image']['S'])))
label = strlabel.replace(""", "")
confidence = strconfidence.replace(""", "")
image = strimage.replace(""", "")
now = datetime.datetime.now().strftime("%Y-%m-%dT%H:%M:%S%z")

        n = 5
        random_str = ''.join([random.choice(string.ascii_letters + string.digits) for i in range(n)])
        url = ("https://elastic-search-endpoint/index/number/"+random_str)
        res = requests.post(url, data=json.dumps({"@timestamp": now, "label": label, "confidence": int(confidence), "image": image}), auth=auth)

試したこと

補足情報（FW/ツールのバージョンなど）

こちらのコードを参考にすればできるということなのですが、数字で指定した1-5の行がネットを調べてモジュールを作成していることはわかるのですが存在意味やこれらをエラーを出さずに実行できる方法が分かりません。

不明点 0. mkdir /dynamodb_to_es**

cd /dynamodb_to_es
pip install requests aws_requests_auth -t .
vi lambda_function.py**```

!/usr/bin/python
-# -- coding: utf-8 -*-

import requests
import json
from aws_requests_auth.aws_auth import AWSRequestsAuth
import random
import string
import datetime
from urlparse import parse_qs

print('Loading function')

def lambda_handler(event, context):
for record in event['Records']:
struser = (record['dynamodb']['NewImage']['user']['S'])
strtime = (record['dynamodb']['NewImage']['time']['S'])
strtask = (record['dynamodb']['NewImage']['task']['S'])
user = struser.replace(""", "")
time = strtime.replace(""", "")
task = strtask.replace(""", "")
now = datetime.datetime.now().strftime("%Y-%m-%dT%H:%M:%S%z")

auth = AWSRequestsAuth(aws_access_key='xxxxxxxxxxxxxxxxxxxx',
                       aws_secret_access_key='xxxxxxxxxxxxxxxxxxxx',
                       aws_host='search-xxxxxxxxxx-1234567890.ap-northeast-1.es.amazonaws.com',
                       aws_region='ap-northeast-1',
                       aws_service='es')
n = 5
random_str = ''.join([random.choice(string.ascii_letters + string.digits) for i in range(n)])
url = ("https://search-xxxxxxxxxx-1234567890.ap-northeast-1.es.amazonaws.com/index_name/number/"+random_str)
res = requests.post(url, data=json.dumps({"@timestamp": now, "user": user, "task": task}), auth=auth)
return (res.content)

5.　zip -r dynamodb_to_es.zip *