问题标签 [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.
amazon-kinesis - 在 Kinesis Analytics 应用程序中为流添加恒定值
在我的 Kinesis Analytics 应用程序中,我想将一个常量字符串添加到我的输出流中。
例如:
我想"MY_CONSTANT_STRING"
用一些字符串值替换。原因是我有很多泵写入我的输出流,所以我想要某种指示使用什么泵。有没有办法做到这一点?
sql-server - 如何在 KINESIS ANALYTICS 中进行 PERCENT_RANK
我正在尝试学习如何进行简单的分析,例如使用 Kinesis Analytics 实时计算价格波动的百分位等级,
我计算每个代码在 1 分钟滑动窗口内的价格波动率,然后尝试对所有代码符号进行百分比排名,并将前 25% 作为选定代码,但是我在 percent_rank 步骤中遇到错误,不确定是因为我没有作为 SQL 专业人士或它只是与运动相关的错误,请分享您的解决方案。提前致谢
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 以防万一一双新鲜的眼睛看到了什么