我是 DynamoDB 的新手。
在我的应用程序中，每个注册用户的帐户上都有一些传感器，这些传感器每 5 分钟就会向我们的数据库发送一些数据。

现在我想显示“如果用户已登录到他的帐户，我应该需要显示他的所有传感器以及每个传感器的最新时间戳值”。

我通过三个查询来完成此操作，例如“我获取了他帐户下的所有设备 -> 原始传感器 ID -> 每个传感器的最新值”，因此执行此过程需要很长时间。

我的表格是这样的:

用户:

---------------------
|sno  | userId      |
---------------------
| 1   | naveenkumar |
|--------------------
| 2   | abc         |
|--------------------
| 3   | xyz         |
|--------------------

传感器设备:

---------------------
| id | sensorId     |
---------------------
| 1  | sensor1      |
|--------------------
| 2  | sensor2      |
|--------------------
| 3  | sensor3      |
|--------------------
| 4  | sensor4      |
---------------------
| 5  | sensor5      |
---------------------

和

用户传感器:

----------------------
| userId | sensorId  |
----------------------
| 1      |  1        |
|---------------------
| 1      |  2        |
|---------------------
| 1      |  4        |
|---------------------
| 2      |  5        |
|---------------------

数据表:

---------------------------------------------
| sensorId  | value    | timestamp          |
---------------------------------------------
| sensor1   | 4.3      | 2014-01-21 11:21:00|
|--------------------------------------------
| sensor2   | 5.0      | 2014-01-21 11:22:00|
|--------------------------------------------
| sensor3   | 10.0     | 2014-01-21 11:19:00|
|--------------------------------------------
| sensor4   | 6.3      | 2014-01-21 11:25:00|
|--------------------------------------------
| sensor1   | 8.3      | 2014-01-21 11:26:00|
|--------------------------------------------
| sensor2   | 6.0      | 2014-01-21 11:27:00|
|--------------------------------------------
| sensor3   | 9.0      | 2014-01-21 11:24:00|
|--------------------------------------------
| sensor4   | 6.3      | 2014-01-21 11:30:00|
|--------------------------------------------

最终输出表将在他的主页上看到用户:

---------------------------------------------
| sensorId  | value    | timestamp          |
---------------------------------------------
| sensor1   | 8.3      | 2014-01-21 11:26:00|
|--------------------------------------------
| sensor2   | 6.0      | 2014-01-21 11:27:00|
|--------------------------------------------
| sensor4   | 6.3      | 2014-01-21 11:30:00|
|--------------------------------------------

我的查询看起来像这样，执行起来需要很长时间，所以请为我提供更好的解决方案:

让我们假设 $_SESSION['login_id'] = 1;

<?php
  $aws = Aws::factory('config.php');
  $client = $aws->get("dynamodb");

  $tableName = "data_tbl";
  echo "<table border=1>";
  echo "<tr>";

  echo "<th>Sensor ID</th>";
  echo "<th>value</th>";
  echo "<th>Timestamp</th>";
  echo "</tr>";

  //Query to get user devices
  $devices = $client->query(array(
    "TableName" => "users-sensors",
    "KeyConditions" => array(
      "userId" => array(
        "ComparisonOperator" => ComparisonOperator::EQ,
        "AttributeValueList" => array(
          array(Type::STRING => $_SESSION['login_id'])
        )
      )
    )
  ));
  foreach ($devices['Items'] AS $key=>$value) {
    $id = $value['sensorId']['S'];
    //Query to get original sensorId from sensor serial number
    $device = $client->query(array(
      "TableName" => "sensor_devices",
      "KeyConditions" => array(
        "id" => array(
          "ComparisonOperator" => ComparisonOperator::EQ,
          "AttributeValueList" => array(
            array(Type::STRING => $id)
          )
        )
      )
    ));
    $dids =  $device['Items'][0]['sensorId'][Type::STRING];
    //Query to get all latest values of sensors
    $response = $client->query(array(
      "TableName" => $tableName,
      "KeyConditions" => array(
        "sensorId" => array(
          "ComparisonOperator" => ComparisonOperator::EQ,
          "AttributeValueList" => array(
            array(Type::STRING => $dids)
          )
        )
      ),
      "Select" => "SPECIFIC_ATTRIBUTES",
      "AttributesToGet" => array("sensorId","value","timestamp"),
      "ScanIndexForward" => false,
      "Limit" => 1  
    ));
    foreach ($response['Items'] AS $key=>$value) {
      echo "<tr>";
      $link = "graph.php?id=".$id;
      echo "<td><a href='$link'>".$value['sensorId']['S']."</a></td>";
      echo "<td><a href='$link'>".$value['value']['S']."</a></td>";
      $epoch = $value['timestamp']['S'];
      $timestamp = date('Y-m-d H:i:s', $epoch);
      echo "<td><a href='$link'>".$timestamp."</a></td>";
      echo "</tr>";
    }
  }
  echo "</table>";
?>

如果我能得到答案，我就能完成我的工作。 谢谢

最佳答案

您正在从关系数据库的角度看待和思考 DynamoDB。 DynamoDB 不是关系数据库。您(通常)不想像在 MySQL 中那样在 DynamoDB 中对数据建模。就像软件开发/计算机科学中的任何事情一样，这是一种权衡。您支付一些数据反规范化和复制成本，以换取极低的查询延迟和极强的可扩展性。

我不使用 PHP，所以我无法帮助您编写代码，但我想我可以帮助您设计数据模型。

如果我正确理解您的要求，则需要在用户登录时获取每个用户的传感器 ID 列表及其最新时间戳。如果是这样，您可以采用以下一种可能的方法将查询次数从 3 次减少到 1 次:

您表的哈希键是 UserID，范围键是传感器事件的 Timestamp:

------------------------
| Hash Key | Range Key |
------------------------
| User ID  | Timestamp |
------------------------

该表将具有 Sensor ID 属性，对应于观察到事件的传感器。传感器 29 于 2014 年 2 月 14 日上午 11:51 观察到的用户 12 的条目可能如下所示:

---------------------------------------
| Hash Key | Range Key     | Sensor ID |
----------------------------------------
|    12    | 1392396884000 |    29     |
----------------------------------------

请注意，我使用了以毫秒为单位的时间戳，以便 DynamoDB 可以轻松地对其进行排序。

现在，当用户登录时，您可以通过用户 ID 查询表以获取该用户的每个事件。在您的查询请求中，设置 ScanIndexForward => false(来自此处的 DynamoDBSDK 文档:http://docs.aws.amazon.com/aws-sdk-php/latest/class-Aws.DynamoDb.DynamoDbClient.html#_query)。 DynamoDB 将按从最近到最不最近的顺序返回您的结果。如果该用户有大量事件，DynamoDB 将相应地对结果集进行分页，但您可以在 DynamoDB 文档中了解如何处理。

现在您有了该用户的事件列表(或 PHP 中的任何相应数据结构)。您需要按 SensorID 进行过滤以获取最新的。好消息是，由于结果是有序的，您只需遍历结果并检查每个项目的 Sensor ID；如果您没有从该 Sensor ID 获得结果，请将其添加到您的过滤集合中。如果您已经从该 Sensor ID 添加了一个事件，则意味着您拥有来自该 Sensor ID 的该 User ID 的最新事件你应该跳过它。

根据您的应用程序的需要，如果您需要获取传感器的每个事件的列表，您可以简单地使用 Sensor ID 的索引散列键在表上放置一个全局二级索引> 和事件 Timestamp。由于 User ID 是表主键的一部分，DynamoDB 会自动将其投影到索引中。

希望对您有所帮助。

关于php - 如何使用 DynamoDB PHP 从表中获取最新的时间戳值，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21250308/