使用Swift制作Amazon AWS DynamoDB查询的最佳方法？

Question

我最近为我的iOS应用程序实施了AWS开发工具包，这是我在Swift中开发的。我已连接到我的数据库实例并能够获得查询响应，但是我正在努力将其转换为可用数据。我对Swift，AWS和一般编程相对陌生，所以可能会错过一些明显的东西！

我的代码如下：

let atVal = AWSDynamoDBAttributeValue() 
    atVal.S = "123456abc" 
    let condition = AWSDynamoDBCondition() 
    condition.comparisonOperator = AWSDynamoDBComparisonOperator.EQ 
    condition.attributeValueList = [atVal] 

    let myDic: [String: AWSDynamoDBCondition] = ["userid": condition] 
    let query = AWSDynamoDBQueryInput() 
    query.indexName = "userid-index" 
    query.tableName = "users" 
    query.keyConditions = myDic 
    query.limit = 1 


    dynamoDB.query(query).continueWithBlock { 
     (task: BFTask!) -> AnyObject! in 
     let results = task.result as AWSDynamoDBQueryOutput 

     let myResults = results.items 
     println("object: \(myResults.description)") 

     return nil 
    } 

而对于此控制台输出是：

对象：[{ 面积= “{\ n S = \” 西浦\“; \ N}“; name =“{\ n S = \”Olly Mayes \“; \ n}”; userid =“{\ n S = \”123456abc \“; \ n}”; }]

可以理解的是，使用AWS和Swift似乎没有太多先例，所以任何帮助都将非常感谢！

Answer 1

您的问题的简单答案是：将返回的JSON字符串转换为Dictionary对象。 事情是这样的：

let data = jsonDataItem.dataUsingEncoding(NSUTF8StringEncoding) 

    if data != nil { 
     var error : NSError? 
     let dict = NSJSONSerialization.JSONObjectWithData(data!, options: NSJSONReadingOptions.AllowFragments, error: &error) as? NSDictionary 

     if let e = error { 
      ... 
     } else { 
      ... 
     } 

不过，我会强烈建议您在较高水平DynamoDB映射类 看当使用DynamoDB映射器类，你定义的数据结构，只是给它DynamoDB Mapper。这是从表格创建到表格删除的完整示例。该示例使用DynamoDB映射器插入，删除，扫描和查询表。

首先，您需要初始化客户端SDK

let cp = AWSStaticCredentialsProvider(accessKey: "AK...", secretKey: "xxx") 
    let configuration = AWSServiceConfiguration(region: AWSRegionType.USEast1, credentialsProvider: cp) 
    AWSServiceManager.defaultServiceManager().setDefaultServiceConfiguration(configuration) 

这仅仅是一个样品。在代码中嵌入Access Key和Secret Key不是一个好习惯。最佳做法是使用AWSCognitoCredentialsProvider代替（read more about Cognito）。

定义你的项目映射表中的一类

class Item : AWSDynamoDBModel, AWSDynamoDBModeling { 

    var email : String = "" 
    var date : String = "" 
    var note : String = "" 
    var number : Double = 0.0 

    override init!() { super.init() } 

    required init!(coder: NSCoder!) { 
     fatalError("init(coder:) has not been implemented") 
    } 

    class func dynamoDBTableName() -> String! { 
     return "Demo" 
    } 
    class func hashKeyAttribute() -> String! { 
     return "email" 
    } 
    class func rangeKeyAttribute() -> String! { 
     return "date" 
    } 

    //required to let DynamoDB Mapper create instances of this class 
    override init(dictionary dictionaryValue: [NSObject : AnyObject]!, error: NSErrorPointer) { 
     super.init(dictionary: dictionaryValue, error: error) 
    } 

    //workaround to possible XCode 6.1 Bug : "Type NotificationAck" does not conform to protocol "NSObjectProtocol" 
    override func isEqual(anObject: AnyObject?) -> Bool { 
     return super.isEqual(anObject) 
    } } 

要创建一个表

self.createTable().continueWithSuccessBlock {(task: BFTask!) -> BFTask! in 
    NSLog("Create table - success") 
    return nil 
} 


func createTable() -> BFTask! { 
    let pt = AWSDynamoDBProvisionedThroughput() 
    pt.readCapacityUnits = 10 
    pt.writeCapacityUnits = 10 

    let emailAttr = AWSDynamoDBAttributeDefinition() 
    emailAttr.attributeName = "email" 
    emailAttr.attributeType = AWSDynamoDBScalarAttributeType.S 

    let dateAttr = AWSDynamoDBAttributeDefinition() 
    dateAttr.attributeName = "date" 
    dateAttr.attributeType = AWSDynamoDBScalarAttributeType.S 

    let emailKey = AWSDynamoDBKeySchemaElement() 
    emailKey.attributeName = "email" 
    emailKey.keyType = AWSDynamoDBKeyType.Hash 

    let dateKey = AWSDynamoDBKeySchemaElement() 
    dateKey.attributeName = "date" 
    dateKey.keyType = AWSDynamoDBKeyType.Range 

    let ct = AWSDynamoDBCreateTableInput() 
    ct.tableName = "Demo" 
    ct.provisionedThroughput = pt 
    ct.attributeDefinitions = [emailAttr, dateAttr] 
    ct.keySchema = [ emailKey, dateKey ] 

    NSLog("Creating table") 

    let client = AWSDynamoDB.defaultDynamoDB() 
    return client.createTable(ct) 
} 

要删除表

self.deleteTable().continueWithSuccessBlock({ (task: BFTask!) -> BFTask! in 
    NSLog("Delete table - success") 
    return nil 
}) 

func deleteTable() -> BFTask! { 

    let dt = AWSDynamoDBDeleteTableInput() 
    dt.tableName = "Demo" 

    NSLog("Deleting table") 
    let client = AWSDynamoDB.defaultDynamoDB() 
    return client.deleteTable(dt) 
} 

插入项目

self.insertSomeItems().continueWithBlock({ 
    (task: BFTask!) -> BFTask! in 

    if (task.error != nil) { 
     NSLog(task.error.description) 
    } else { 
     NSLog("DynamoDB save succeeded") 
    } 

    return nil; 
}) 

func insertSomeItems() -> BFTask! { 
    let mapper = AWSDynamoDBObjectMapper.defaultDynamoDBObjectMapper() 

    var item = Item() 
    item.email = "[email protected]" 
    item.date = "20141101" 
    item.note = "This is item #1" 
    item.number = 1.0 
    let task1 = mapper.save(item) 

    item = Item() 
    item.email = "[email protected]" 
    item.date = "20141102" 
    item.note = "This is item #2" 
    item.number = 2.0 
    let task2 = mapper.save(item) 

    item = Item() 
    item.email = "[email protected]" 
    item.date = "20141103" 
    item.note = "This is item #3" 
    item.number = 3.0 
    let task3 = mapper.save(item) 

    return BFTask(forCompletionOfAllTasks: [task1, task2, task3]) 
} 

要加载一个单一项目

self.load("[email protected]", range:"20141101").continueWithSuccessBlock({ (task: BFTask!) -> BFTask! in 
    NSLog("Load one value - success") 
    let item = task.result as Item 
    print(item) 
    return nil 
}) 


func load(hash: String, range: String) -> BFTask! { 
    let mapper = AWSDynamoDBObjectMapper.defaultDynamoDBObjectMapper() 
    return mapper.load(Item.self, hashKey: hash, rangeKey: range) 

} 

要在哈希和范围键

/* 
    keyConditions 
    http://docs.aws.amazon.com/AWSiOSSDK/latest/Classes/AWSDynamoDBQueryInput.html#//api/name/keyConditions 
*/ 
let cond = AWSDynamoDBCondition() 
let v1 = AWSDynamoDBAttributeValue(); v1.S = "20141101" 
cond.comparisonOperator = AWSDynamoDBComparisonOperator.EQ 
cond.attributeValueList = [ v1 ] 
let c = [ "date" : cond ] 
self.query("[email protected]", keyConditions:c).continueWithSuccessBlock({ (task: BFTask!) -> BFTask! in 
    NSLog("Query multiple values - success") 
    let results = task.result as AWSDynamoDBPaginatedOutput 
    for r in results.items { 
     print(r) 
    } 
    return nil 
}) 

func query(hash: String, keyConditions:[NSObject:AnyObject]) -> BFTask! { 
    let mapper = AWSDynamoDBObjectMapper.defaultDynamoDBObjectMapper() 

    let exp = AWSDynamoDBQueryExpression() 
    exp.hashKeyValues  = hash 
    exp.rangeKeyConditions = keyConditions 

    return mapper.query(Item.self, expression: exp) 
} 

要扫描的项目（完整的查询表扫描）

let cond = AWSDynamoDBCondition() 
let v1 = AWSDynamoDBAttributeValue(); v1.S = "20141101" 
cond.comparisonOperator = AWSDynamoDBComparisonOperator.GT 
cond.attributeValueList = [ v1 ] 

let exp = AWSDynamoDBScanExpression() 
exp.scanFilter = [ "date" : cond ] 

self.scan(exp).continueWithSuccessBlock({ (task: BFTask!) -> BFTask! in 
    NSLog("Scan multiple values - success") 
    let results = task.result as AWSDynamoDBPaginatedOutput 
    for r in results.items { 
     print(r) 
    } 
    return nil 
}) 

func scan(expression : AWSDynamoDBScanExpression) -> BFTask! { 

    let mapper = AWSDynamoDBObjectMapper.defaultDynamoDBObjectMapper() 
    return mapper.scan(Item.self, expression: expression) 
} 

如果你有DynamoDB在美国东1没有其他用途，不存在与运行这个样本，因为它是落入DynamoDB's free tier相关的成本。