前提・実現したいこと
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 *
あなたの回答
tips
プレビュー