问题标签 [amazon-timestream]

返回错误line 20:3: Given correlated subquery is not supported但根据Timestream 子查询支持

Timestream 查询语言支持相关子查询和其他子查询。

列：

cpuMode, 主机, 设备, cpuCode, 收集器, measure_value::double, measure_name, time,

样本数据：

空闲，MacBook-Pro.local，-，0，cpu，115950.13，cpu_seconds_total，2021-04-29 13:46:11.000000000

期望的输出：

主机、时间、利用率

MacBook-Pro.local 2021-04-29 13:47:56.000000000 15

MacBook-Pro.local 2021-04-29 13:47:41.000000000 16

MacBook-Pro.local 2021-04-29 13:47:26.000000000 19

我正在尝试使用公式 (1 - idleTime / totalTime) * 100 计算 CPU 利用率，但显然不支持这些相关的子查询。我只需要以不同的方式重写它吗？

在求和子查询中，我试图计算在主查询之前收到的度量值的总和，我正在使用and time <= h.time导致查询相关的行来执行此操作，从而导致问题。

万分感谢

这个项目是通过AWS Timestream来记录数据的，效果很好。

但是，我无法使用 jest 来模拟 AWS TimestreamWrite。我尝试了一些方法，但没有奏效。有人能帮我吗？

我的文件如下：

分类帐服务.js

分类帐服务.spec.js

我只是认为我嘲笑的 AWS 没有传递到ledger-service.js. 有没有办法解决这个问题？

谢谢

更新：采纳 hoangdv 的建议

我在想jest.resetModules(); jest.resetAllMocks();不工作。如果我将“它应该在所有成功时写入记录”作为第一个测试，它将通过测试。但是，如果前面有一个，它将失败。

经过

失败的

我正在尝试使用 iot 核心规则来定义一个将 JSON 对象发送到时间流表的操作。该对象如下所示：

{ "Time": 1483715700000, "TimeUnit": "MILLISECONDS", "endpointID": "ahu3", "Introduction_temperature": 15.8 }

sql查询：

我想在对象中使用时间戳：（在规则中定义）

Value: ${Time} Unit: MILLISECOND

当我尝试使用我的时间戳时，表中没有任何内容！只有当我不使用我的时间戳时它才有效。有没有人遇到过这个问题？谢谢

我将遥测推送到 AWS 时间流：

我希望在时间流中显示数据的聚合，向我显示每小时每个 uri 的点击次数。

我正在尝试使用：

但我得到了错误：

我使用了错误的功能还是我的数据有误？

====================

尝试@berto99 的解决方案...我得到：

======================

更新#2：

到达那里，仍然没有 100% 到达那里。

我们有一个移动应用程序，用户可以在其中写一些相当私人的东西。

如果他们同意，我们希望以完全匿名的方式存储这些著作（几句话）。

我们有一个 IA 可以帮助用户纠正写作。因此，我们还需要在用户更正之前和之后存储每个句子的版本。

我们可以存储句子并具有这样的结构：

• 当前写入会话 UUID（不可与用户链接）
• 句子
• 模型预测（良好/待纠正）
• 是用户后来更正了还是用户保留了它？

所有这些句子都需要在发送到模型训练数据之前进行人工审核和标记。

分析将在 Jupyter Notebooks 上进行。它可以在本地计算机上完成。

我们将分块进行分析。每个月每个示例。然后，我们提取一些关于当前训练集似乎是新的数据，将其发送给将手动标记它的专家。

我们预计每月最多有几十万个句子。

我有几个想法来存储它，但我远没有足够的知识来理解所有的利弊。

• 在 S3 上存储 CSV 文件
• 将其存储为 RDS 中的 SQL 表
• 使用按需模式将其存储在 Amazon DynamoDB 中。
• 将其存储为 Amazon CloudWatch Logs（如果可能？）
• 将其作为 TimeSerie 存储在 Amazon TimeStream 中

直观地说，我会使用 RDS，因为它是普通的、经典的 SQL。但是我怀疑所有其他解决方案都会便宜得多。

您对此用例有什么见解或建议吗？

问候

我正在尝试使用 AWS Timestream 作为股票分析应用程序的 POC 的数据源。我计划以数据库中可用的最低间隔保存股票数据，然后查询所需的时间范围。

到目前为止，我尝试的是使用窗口函数。

但我就是无法让它工作。我已经尝试了以下查询：

结果是

第 3:2 行：'"first_value"(measure_value::double) OVER (PARTITION BY "BIN"(time, INTERVAL '15' MINUTE))' 必须是聚合表达式或出现在 GROUP BY 子句中

结果是

第 8:2 行：GROUP BY 子句不能包含聚合、窗口函数或分组操作：["first_value"(measure_value::double) OVER (PARTITION BY "BIN"(time, INTERVAL '15' MINUTE))]

这两个有点矛盾。两者都说以另一种方式做，但另一种方式说像以前一样做..

所以我有点卡在这里，我的 SQL 技能并不离谱。任何帮助表示赞赏。

我正在尝试写入我创建的 Timestream 数据库。但是，在此之前，应该说明我的 AWS 账户设置了一个 DEV 账户和一个我的角色切换到的 Prod 账户。

我在 cloudformation 中创建了 Timestream 数据库和表，并将其部署到 DEV 帐户。

然后我去了我的 pycharm 编辑器并编写了一个脚本来将数据摄取到这个表中

但是，我不断收到错误 botocore.errorfactory.ResourceNotFoundException: An error occurred (ResourceNotFoundException) when calling the WriteRecords operation: The table Experiment does not exist。

该表确实存在，我可以在 DEV 账户的 AWS 控制台中验证这一点，并通过在 DEV 账户中调用 timestream-write list-tables cli 调用

我认为 pycharm 编辑器在运行脚本时尝试连接到管理员帐户，但不完全确定。我在我的 pycharm 编辑器中切换到 DEV 帐户，所以也许它可能是别的东西？

我应该补充一点，如果我将 CF 模板部署到主帐户中，然后运行我的脚本，它就可以正常工作。所有数据都导入到在主帐户中创建的数据库和表中。

当我在 DEV 帐户中执行完全相同的步骤时，它就不起作用了

任何帮助，将不胜感激！

对于一个简单的查询，例如：

SELECT measure_value::varchar FROM "mydb"."mytable" LIMIT 5

产生：

如何修改查询以显示：

我有一个设置，我使用 Grafana 从时间流中查询内容。我在 Grafana 中设置了一个区间变量，用于时间戳分箱（将结果分成 10 秒或 15 米的块）。我从 timestream 查询的字段是该特定时间间隔内发出的 HTTP 请求总数。

我想做的是使用该间隔变量作为在该特定间隔内发出的 HTTP 请求总数的分隔符。这将允许我计算每秒请求数 (RPS)。

我在使用时间流中的间隔数据类型进行除法时遇到了困难。AWS 文档没有提供太多将区间类型转换为其他类型的方法，而且强制转换也不起作用。

我已经尝试在谷歌上搜索替代方案，并为其他查询语言提供了 extract 和 time_part，但我还没有找到任何适用于 timestream 的方法。

这是我尝试执行的查询类型的示例，Rate 是间隔：

编辑：我有一种非常老套的方法可以将 15m 和 10s 等间隔转换为整数秒。必须有更好的方法来做到这一点，我太无能了。

从我的 NodeJS 环境中查询 Timestream DB 时，我遇到了一些问题。我收到一个空数组来响应所有响应较大的查询当我使用控制台时，完全相同的查询正在工作。所以我确信查询语法和格式是正确的。文档说当响应大于 1 MB 时使用分页。所以我应该收到带有 nextPageToken 的分页响应，但我得到的是 []。

我注意到 MaxRows 参数不起作用的另一件事。所以有一个查询返回 84 行。当我通过 MaxRows = 83 或小于该值的任何值时，我收到空数组作为响应，当我通过 MaxRows = 84 或更多值时，我收到实际响应。

基于这些观察，我认为分页不起作用。关于如何解决这个问题的任何想法？