import json
import base64
import urllib.request
import os
def fnGetToken():
url = os.environ['authurl']
headers = {}
key = os.environ['okey']
secret = os.environ['osecret']
authHeader = 'Basic ' + str(base64.b64encode(bytes((key + ':' + secret), 'utf-8')), "utf-8")
headers['Authorization'] = authHeader
headers['ContentType'] = 'application/x-www-form-urlencoded;charset=UTF-8'
data = "grant_type=client_credentials"
req = urllib.request.Request(url, headers = headers, method = 'POST')
response = urllib.request.urlopen(req, data.encode('utf-8'))
respData = response.read()
data = json.loads(respData)
return data['access_token']
import json
import boto3
ddbclient = boto3.client('dynamodb')
def lambda_handler(event, context):
#event['queryStringParameters']['team']
ddbclient = boto3.client('dynamodb')
#teamname = event['queryStringParameters']['teamname']
#dctParams = parse.parse_qs(event['body'])
#teamname = dctParams['teamname']
#data = json.loads(event['body'])
#teamname = data['teamname']
#response = ddbclient.put_item(Item={'pk': { 'S': 'game1' }, 'sk': { 'S': 'team'}, 'teamname': { 'S': teamname}}, TableName='UnifiedTable')
#response = client.get_item( TableName='UnifiedTable', Key={ 'pk': { 'S': 'game1' }, 'sk': { 'S': 'team' } }, AttributesToGet=[ 'teamname' ] )
response = ddbclient.query( TableName='UnifiedTable', KeyConditions={'pk': { 'AttributeValueList': [ { 'S': 'game1' } ],'ComparisonOperator': 'EQ'}})
print(response)
return {'statusCode': 200, 'headers': { 'Content-Type': 'text/plain', 'Access-Control-Allow-Origin': '*','Access-Control-Allow-Methods':'*' }, 'body': json.dumps(response['Items']) }