your-recommend/amazon_ecs.py at master · bugcloud/your-recommend · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
#!Python2.6
# -*- coding: utf-8 -*-
import urllib
from datetime import datetime
import hashlib, hmac
import base64
import os
from django.conf import settings
settings._target = None
os.environ["DJANGO_SETTINGS_MODULE"] = "settings"

ECS_URL = getattr(settings, "ECS_URL", 'http://ecs.amazonaws.jp/onca/xml')
ACCESS_KEY_ID = getattr(settings, "ACCESS_KEY_ID", None)
ASSOCIATE_TAG = getattr(settings, "ASSOCIATE_TAG", None)
SECRET_ACCESS_KEY = getattr(settings, "SECRET_ACCESS_KEY", None)
HTTP_REQUEST_URI = getattr(settings, "HTTP_REQUEST_URI", 'ecs.amazonaws.jp')

class Operation:
    __safe_chars = '-._~'
    __ecs_url = ECS_URL
    __service = 'AWSECommerceService'
    __access_key_id = ACCESS_KEY_ID
    __associate_tag = ASSOCIATE_TAG
    __secret_access_key = SECRET_ACCESS_KEY
    __http_verb = 'GET'
    __value_of_host_header_in_lowercase = '/onca/xml'
    __http_request_uri = HTTP_REQUEST_URI
    def __init__(self):

        self.__param_map = {}

    def operation_name(self):
        return ''

    def request(self):
        self.set_parameter('Service', self.__service)
        self.set_parameter('AWSAccessKeyId', self.__access_key_id)
        self.set_parameter('AssociateTag', self.__associate_tag)
        self.set_parameter('Operation', self.operation_name())
        self.set_parameter('Timestamp', datetime.utcnow().isoformat() + 'Z')
        #Name-Value Pairs
        n_v_pair_list = []
        for key in self.__param_map.keys():
            n_v_pair_list.append(urllib.quote(key, self.__safe_chars) + '=' + urllib.quote(self.__param_map[key], self.__safe_chars))

        #Sorted Pairs
        n_v_pair_list.sort()
        request_parm_str = '&'.join(n_v_pair_list)
        #String-To-Sign
        sing_part_list = [self.__http_verb, self.__http_request_uri, self.__value_of_host_header_in_lowercase, request_parm_str]
        str_to_sign = '\n'.join(sing_part_list)
        hmac_digest = hmac.new(self.__secret_access_key, str_to_sign, hashlib.sha256).digest()
        base64_encoded = base64.b64encode(hmac_digest)
        signature = urllib.quote(base64_encoded);
        return '%s?%s&Signature=%s' % (self.__ecs_url, request_parm_str, signature)
    def set_parameter(self, key, value, remove=False):
        if remove:
            del self.__param_map[key]
        else:
            self.__param_map[key] = value
    def response_group(self, value, remove=False):
        self.set_parameter('ResponseGroup', value=value, remove=False)

class ItemSearch(Operation):
    '''
    @see: http://docs.amazonwebservices.com/AWSECommerceService/latest/DG/index.html?ItemSearch.html
    '''
    def operation_name(self):
        return 'ItemSearch'
    def keywords(self, value, remove=False):
        self.set_parameter('Keywords', value, remove)
    def search_index(self, value='Books', remove=False):
        self.set_parameter('SearchIndex', value, remove)

class ItemLookup(Operation):
    '''
    @see: http://docs.amazonwebservices.com/AWSECommerceService/latest/DG/index.html?ItemSearch.html
    '''
    def operation_name(self):
        return 'ItemLookup'
    def itemid(self, value, remove=False):
        self.set_parameter('ItemId', value, remove)