javascript – 使用AWS SDK for Node.js将项目放在DynamoDB表上（aws 部署web应用）

25-02-07 19

在本文中，我们将给您介绍关于javascript–使用AWSSDKforNode.js将项目放在DynamoDB表上的详细内容，并且为您解答aws部署web应用的相关问题，此外，我们还将为您提供关于A

在本文中，我们将给您介绍关于javascript – 使用AWS SDK for Node.js将项目放在DynamoDB表上的详细内容，并且为您解答aws 部署web应用的相关问题，此外，我们还将为您提供关于Aws sdk for java,dynamo db mapper async、com.amazonaws.services.dynamodb.datamodeling.DynamoDBAttribute的实例源码、com.amazonaws.services.dynamodb.datamodeling.DynamoDBHashKey的实例源码、com.amazonaws.services.dynamodb.datamodeling.DynamoDBMapper的实例源码的知识。

本文目录一览：

javascript – 使用AWS SDK for Node.js将项目放在DynamoDB表上（aws 部署web应用）
Aws sdk for java,dynamo db mapper async
com.amazonaws.services.dynamodb.datamodeling.DynamoDBAttribute的实例源码
com.amazonaws.services.dynamodb.datamodeling.DynamoDBHashKey的实例源码
com.amazonaws.services.dynamodb.datamodeling.DynamoDBMapper的实例源码

javascript – 使用AWS SDK for Node.js将项目放在DynamoDB表上（aws 部署web应用）

我是 javascript和node.js的新手,并且想知道有人可以帮助我找出通过其node.js SDK将新项目放在AWS Dynamodb上的现有表上的语法.这是我到目前为止.有什么我想要做的例子吗？如果有人能指出我正确的方向,那将是非常感激的.

var AWS = require('aws-sdk');
AWS.config.loadFromPath('./config.json');
AWS.config.update({region: 'us-east-1'});
var dynamodb = new AWS.DynamoDB();

var item = {
    // I need to put the an item with a the primary key of "id",and an attribute called "item"
    // I'm new to js and node.js,so if somebody Could help me understand the documentation
    // http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/frames.html#!http%3A//docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB_20120810.html
}

dynamodb.putItem({TableName: 'log_dev',Item: item},function(err,data){
    if (err) {
    console.log(err); // an error occurred
    } else {
    console.log(data); // successful response
    }
});

解决方法

dynamoDB.putItem(
{
    "TableName": "Table1","Item": {
        "Color": {"S": "white"},"Name": {"S": "fancy vase"},"Weight": {"N": "2"},"LastName":{"S": "Kumar"}
    }
},function(result) {
    result.on('data',function(chunk) {
        console.log("" + chunk);
    });
});
console.log("Items are succesfully ingested in table ..................");

Aws sdk for java,dynamo db mapper async

在Amazon Web Services sdk for java中,有可能为DynamoDB创建两个不同的客户端：sync和async.然后可以将这两个对象传递给DynamoDBMapper的构造函数.所以,你应该可以创建两种不同类型的DynamoDBMapper：同步映射器和异步映射器.

我的问题是：异步映射器如何工作？我在异步映射器中找不到任何返回Future对象的方法.那么,如果我必须总是等待异步映射器的任何方法的返回值,我如何能异步运行多个查询？

谢谢

解决方法

异步DynamoDB客户端从同步客户端扩展,并为返回Futures的异步操作提供新的方法名称.目前,DynamoDBMapper将始终使用您传入的任何AmazonDynamoDB客户端的同步方法.我们将使用映射器将此反馈作为异步支持的功能请求.

com.amazonaws.services.dynamodb.datamodeling.DynamoDBAttribute的实例源码

项目：gora-boot 文件：person.java

@DynamoDBAttribute(attributeName = "LastName")
public String getLastName() {  return lastName;  }

项目：gora-boot 文件：person.java

@DynamoDBAttribute(attributeName = "Visitedplaces")
public Set<String> getVisitedplaces() {  return visitedplaces;  }

项目：gora-boot 文件：person.java

@DynamoDBAttribute(attributeName = "Salary")
public double getSalary() {  return salary;  }

项目：gora-boot 文件：person.java

@DynamoDBAttribute(attributeName = "FirstName")
public String getFirstName() {  return firstName;  }

项目：ridebuddy 文件：Credentials.java

@DynamoDBAttribute
public String getFirstName() {
    return firstName;
}

项目：ridebuddy 文件：Credentials.java

@DynamoDBAttribute
public String getLastName() {
    return lastName;
}

项目：ridebuddy 文件：Credentials.java

@DynamoDBAttribute
public String getImgSrc() {
    return imgSrc;
}

项目：ridebuddy 文件：Credentials.java

@DynamoDBAttribute
public String getpassword() {
    return password;
}

项目：ridebuddy 文件：Posts.java

@DynamoDBAttribute
public String getContent() {
    return content;
}

项目：ridebuddy 文件：Posts.java

@DynamoDBAttribute
public String getPostId() {
    return postId;
}

项目：gora-oraclenosql 文件：person.java

@DynamoDBAttribute(attributeName = "LastName")
public String getLastName() {  return lastName;  }

项目：gora-oraclenosql 文件：person.java

@DynamoDBAttribute(attributeName = "Visitedplaces")
public Set<String> getVisitedplaces() {  return visitedplaces;  }

项目：gora-oraclenosql 文件：person.java

@DynamoDBAttribute(attributeName = "Salary")
public double getSalary() {  return salary;  }

项目：gora-oraclenosql 文件：person.java

@DynamoDBAttribute(attributeName = "FirstName")
public String getFirstName() {  return firstName;  }

com.amazonaws.services.dynamodb.datamodeling.DynamoDBHashKey的实例源码

项目：gora-boot 文件：person.java

@DynamoDBHashKey(attributeName="ssn") 
public String getHashKey() {  return ssn; }

项目：ridebuddy 文件：Credentials.java

@DynamoDBHashKey(attributeName="email")
public String getEmail() {
    return email;
}

项目：ridebuddy 文件：Rides.java

@DynamoDBHashKey(attributeName="postId")
public String getPostId() {
    return postId;
}

项目：ridebuddy 文件：Posts.java

@DynamoDBHashKey(attributeName="email")
public String getEmail() {
    return email;
}

项目：support 文件：WeiboBuzzVolume.java

@DynamoDBHashKey(attributeName="keyword")
public String getKeyword() {
    return keyword;
}

项目：gora-oraclenosql 文件：person.java

@DynamoDBHashKey(attributeName="ssn") 
public String getHashKey() {  return ssn; }

com.amazonaws.services.dynamodb.datamodeling.DynamoDBMapper的实例源码

项目：gora-boot 文件：DynamoDBStore.java

/**
 * Executes a query after building a DynamoDB specific query based on the received one
 */
@Override
public Result<K,T> execute(Query<K,T> query) {
  DynamoDBQuery<K,T> dynamoDBQuery = buildDynamoDBQuery(query);
  DynamoDBMapper mapper = new DynamoDBMapper(dynamoDBClient);
  List<T> objList = null;
  if (DynamoDBQuery.getType().equals(DynamoDBQuery.RANGE_QUERY))
    objList = mapper.query(persistentClass,(DynamoDBQueryExpression)dynamoDBQuery.getQueryExpression());
    if (DynamoDBQuery.getType().equals(DynamoDBQuery.SCAN_QUERY))
      objList = mapper.scan(persistentClass,(DynamoDBScanExpression)dynamoDBQuery.getQueryExpression());
      return new DynamoDBResult<K,T>(this,query,objList);  
}

项目：gora-boot 文件：DynamoDBStore.java

/**
 * Puts an object identified by a key
 * @throws IOException
 */
@Override
public void put(K key,T obj) {
  try{
    Object rangeKey = getRangeKey(key);
    Object hashKey = getHashKey(key);
    // if the key does not have these attributes then try to get them from the object
    if (hashKey == null)
      hashKey = getHashKey(obj);
    if (rangeKey == null)
      rangeKey = getRangeKey(obj);
    if (hashKey != null){
      DynamoDBMapper mapper = new DynamoDBMapper(dynamoDBClient);
      if (rangeKey != null)
        mapper.load(persistentClass,hashKey.toString(),rangeKey.toString());
      else
        mapper.load(persistentClass,hashKey.toString());
        mapper.save(obj);
    }
    else
      throw new GoraException("Error while retrieving keys from object: " + obj.toString());
  }catch(NullPointerException npe){
    LOG.error("Error while putting an item. " + npe.toString());
    npe.printstacktrace();
  }catch(Exception e){
    LOG.error("Error while putting an item. " + obj.toString());
    e.printstacktrace();
  }
}