ASJServer/Object/AWS/DynamodbObject.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
@Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
@AUTHOR: ASJRD018
@NAME: AnsjerFormal
@software: PyCharm
@DATE: 2019/10/9 16:17
@Version: python3.6
@MODIFY DECORD:ansjer dev
@file: DynamodbObject.py
@Contact: chanjunkai@163.com
"""
from boto3 import Session
from botocore.exceptions import ClientError
from boto3.dynamodb.conditions import Key, Attr
import logging
import json
import boto3
from var_dump import var_dump

# AWS_DynamoDB_REGION = ''
# AWS_DynamoDB_ACCESS_KEY = ''
# AWS_DynamoDB_SECRET_KEY = ''
AWS_DynamoDB_REGION = 'us-west-1'
AWS_DynamoDB_ACCESS_KEY = 'AKIA2E67UIMD4PZTYKYD'
AWS_DynamoDB_SECRET_KEY = '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'


class DynamodbObject(object):
    def __init__(self, *args, **kwargs):
        self.region = AWS_DynamoDB_REGION
        self.access_key = AWS_DynamoDB_ACCESS_KEY
        self.secret_key = AWS_DynamoDB_SECRET_KEY
        self.session = Session(aws_access_key_id=self.access_key,
                               aws_secret_access_key=self.secret_key,
                               region_name=self.region)

    def do_table_handle(self, table_name):
        dynamodb = self.session.resource('dynamodb')
        table_handle = dynamodb.Table(table_name)
        return table_handle

    def do_san(self, filter_data, table_name):
        var_dump('xjklfjl;asjl;sdf')
        table_handle = self.do_table_handle(table_name)
        response = table_handle.scan(
            ProjectionExpression="userID",
            FilterExpression=Attr('appId').eq('com.ansjer.zccloud'),
        )
        var_dump('xxloo')
        var_dump(response)
        var_dump('****************')
        items = response['Items']

        return ''


# dobj = DynamodbObject()
# res = dobj.do_san(filter_data={'appId': 'com.ansjer.zccloud'}, table_name='user_brand')