问题标签 [amazon-kinesis-analytics-sql]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
222 浏览

amazon-kinesis - 在 Kinesis Analytics 应用程序中为流添加恒定值

在我的 Kinesis Analytics 应用程序中,我想将一个常量字符串添加到我的输出流中。

例如:

我想"MY_CONSTANT_STRING"用一些字符串值替换。原因是我有很多泵写入我的输出流,所以我想要某种指示使用什么泵。有没有办法做到这一点?

0 投票
0 回答
113 浏览

sql-server - 如何在 KINESIS ANALYTICS 中进行 PERCENT_RANK

我正在尝试学习如何进行简单的分析,例如使用 Kinesis Analytics 实时计算价格波动的百分位等级,

我计算每个代码在 1 分钟滑动窗口内的价格波动率,然后尝试对所有代码符号进行百分比排名,并将前 25% 作为选定代码,但是我在 percent_rank 步骤中遇到错误,不确定是因为我没有作为 SQL 专业人士或它只是与运动相关的错误,请分享您的解决方案。提前致谢

0 投票
0 回答
272 浏览

amazon-kinesis-analytics - 如何对 Kinesis Analytics SQL 应用程序进行故障排除?

我有一个通过 CloudFormation 部署的 KA SQL 应用程序。它旨在读取 kinesis 流的数据,然后运行简单的 SQL 计数查询并将数据输出到 Firehose。Firehose 应该将这些数据写入 S3。不幸的是,数据无处可寻。我 89% 确定问题出在 SQL 脚本中,但如果没有日志,就很难查明根本原因。

语境:

  • 通过 CloudFormation API 配置 KA SQL 时不会出现“权限/访问被拒绝”错误。
  • KA SQL 启用了 CloudWatch 日志记录,以前在修复之前显示配置错误。
  • Firehose 具有将数据写入 S3 的正确权限。通过 Firehose UI 测试。
  • 不幸的是,目前我无法访问 Kinesis 分析 UI,因为我缺乏通过 UI 创建应用程序的权限。

怀疑:

  • 位于 CFT 中的 SQL 脚本中的流氓引号是通过对流层生成的
  • 取自 AWS 示例并稍作修改的 SQL 脚本中的错误
  • 某处缺少许可?

主要问题:鉴于有许多活动部件(KA app/Firehose/S3/Kinesis),您通过不同的 CloudWatch 指标和日志流对其进行监控,您如何检查您的 SQL 是否简单损坏?这个问题可能听起来很傻,但想象一下您的 SQL 字符串通过某些工具被翻译并包含到 CFT 模板中。

PS 我附上了 CFT 以防万一一双新鲜的眼睛看到了什么