Kapacitor：基于流数据的批量查询

编程问答 2022-08-15

问题描述

我想作为BatchNode查询查找另一个度量。 where子句应基于kapacitor的流数据。

假设有大量数据要测量，例如@H_404_3@ ABC 是

time                email       owner ID    
----                -----       ----- ------
1598266815000000000 [email protected] ABC   ABC123

我从流数据中获得了测量名称@H_404_3@ ABC 作为标签键之一，例如@H_404_3@ name 。我想进行查找以获取来自测量@H_404_3@ ABC

的电子邮件 
    |from()
        .database(db)
        .retentionPolicy(rp)
        .measurement(measurement)
        .groupBy(groupBy)
        .where(whereFilter)
    |eval(lambda: "value")
        .as('value')

var lookup = batch
    | query('select * from "'+ Vara + '" ORDER BY desc LIMIT 1')

其中Vara = ABC。

我想知道是否有办法做到这一点。要从数据中获取标签名称，例如 Vara. = {{ index .Tags "name" }}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

chronografinfluxdbinfluxqlkapacitor