名称 'Key' 未定义访问 DynamoDB 的 Lambda 函数

Question

我在 Python 中使用 boto3 库的查询函数并收到以下错误：

name 'Key' is not defined: NameError
Traceback (most recent call last):
File "/var/task/lambda_function.py", line 51, in lambda_handler
if not getAssetExistance(slack_userID):
File "/var/task/lambda_function.py", line 23, in getAssetExistance
response = dynamoTable.query(KeyConditionExpression=Key('userID').eq(asset))
NameError: name 'Key' is not defined

我一直在阅读大量关于通过 Lambda 访问 DynamoDB 的教程，他们都在尝试是否存在密钥时使用此 KeyConditionExpression 行。

相关代码如下（第23行为查询行）：

def getAssetExistance(asset):
    dynamoTable = dynamo.Table('Assets')
    response    = dynamoTable.query(KeyConditionExpression=Key('userID').eq(asset))

    return bool(response)

我基本上想检查我的 DynamoDB table 中的主分区键（这是一个 slack 用户 ID）并查看是否存在。

如果相关，下面是其余代码：

################################
# Slack Lambda handler.
################################

import boto3
import logging
import os
import urllib

# Grab data from the environment.
BOT_TOKEN   = os.environ["BOT_TOKEN"]
ASSET_TABLE = os.environ["ASSET_TABLE"]
REGION_NAME = os.getenv('REGION_NAME', 'us-east-1')

dynamo = boto3.resource('dynamodb', region_name=REGION_NAME, endpoint_url="https://dynamodb.us-east-1.amazonaws.com")

# Define the URL of the targeted Slack API resource.
SLACK_URL = "https://slack.com/api/chat.postMessage"

def getAssetExistance(asset):
    dynamoTable = dynamo.Table('Assets')
    response    = dynamoTable.query(KeyConditionExpression=Key('userID').eq(asset))

    return bool(response)

def lambda_handler(data, context):
    # Slack challenge answer.
    if "challenge" in data:
        return data["challenge"]

    # Grab the Slack channel data.
    slack_event    = data['event']
    slack_userID   = slack_event["user"]
    slack_text     = slack_event["text"]
    channel_id     = slack_event["channel"]
    slack_reply    = ""

    # Ignore bot messages.
    if "bot_id" in slack_event:
        slack_reply = ""
    else:

        # Start data sift.
        if slack_text.startswith("!networth"):
            slack_reply = "Your networth is: "
        elif slack_text.startswith("!price"):
            command,asset = text.split()
            slack_reply = "The price of a(n) %s is: " % (asset)
        elif slack_text.startswith("!addme"):
            if not getAssetExistance(slack_userID):
                slack_reply = "Adding user: %s" % (slack_userID)
                dynamo.update_item(TableName=ASSET_TABLE, 
                    Key={'userID':{'S':'slack_userID'}},
                    AttributeUpdates= {
                        'resources':{
                            'Action': 'ADD',
                            'Value': {'N': '1000'}
                        }
                    }
                )
            else:
                slack_reply = "User %s already exists" % (slack_userID)

        # We need to send back three pieces of information:
        data = urllib.parse.urlencode(
            (
                ("token", BOT_TOKEN),
                ("channel", channel_id),
                ("text", slack_reply)
            )
        )
        data = data.encode("ascii")

        # Construct the HTTP request that will be sent to the Slack API.
        request = urllib.request.Request(
            SLACK_URL, 
            data=data, 
            method="POST"
        )
        # Add a header mentioning that the text is URL-encoded.
        request.add_header(
            "Content-Type", 
            "application/x-www-form-urlencoded"
        )

        # Fire off the request!
        urllib.request.urlopen(request).read()

    # Everything went fine.
    return "200 OK"

我的 DynamoDB table 名为 'Assets' 并且有一个名为 'userID'（字符串）的主分区键。

我对这一切肯定还是陌生的，所以不要害怕称我为傻瓜。任何和所有的帮助表示赞赏。此代码的目标是检查用户是否作为 DynamoDB 中的键存在，如果不存在，则将其添加到 table.

Answer 1

你需要导入Key函数，像这样：

from boto3.dynamodb.conditions import Key

Answer 2

无需第二次导入，您可以这样处理： boto3.dynamodb.conditions.Key

def getAssetExistance(asset):
dynamoTable = dynamo.Table('Assets')
response    = dynamoTable.query(KeyConditionExpression= boto3.dynamodb.conditions.Key('userID').eq(asset))

return bool(response)

Answer 3

编写了以下代码以从 dynamo 数据库获取数据并收到错误“NameError: name 'Key' is not defined”。

我不得不通过导入来修复它 'from boto3.dynamodb.conditions import Key'

            response = dynamo_table.query(KeyConditionExpression=Key(val).eq(str(key_dictionary[val])))

名称 'Key' 未定义访问 DynamoDB 的 Lambda 函数

Name 'Key' not defined Lambda function to access DynamoDB

python-3.x

amazon-dynamodb

slack-api

aws-lambda