当我编译influxDB时,我遇到了一个问题。我找不到flux.pc文件。 错误信息为: skyfire@skyfire:~/goproject/src/github.com/influxdata/influxdb$ go install ./...
# /bin/pkg-config --cflags -- flux
Package flux was not found in the pkg-config search path.
Perhaps you should add the directory containing `flux.pc'
to the PKG_CONFIG
我想使用grafana来监视数据,利用FLUX查询语言的数学能力。为此,我设置了influxdb和grafana服务器,并安装了telegraf。 user@Logger-0271:~$ influx
Connected to http://localhost:8086 version 1.8.2
InfluxDB shell version: 1.8.2
> show databases
name: databases
name
----
_internal
localdb
brunosdb
telegraf
> use brunosdb
Using database brun
在Grafana中,我有一个仪表板,它使用Flux1.x作为数据源,我正在迁移它以使用Flux2.0数据源和InfluxDB查询。 在Grafana仪表板中有一个名为"Server“的变量,它定义了以下查询: SHOW TAG VALUES ON telegraf WITH KEY = "host" 我真的很难用Flux query创建一个类似的变量。你知道怎么做到这一点吗?谢谢
使用InfluxQL和此查询,可以将表从Float转换为Integer
SELECT value::integer INTO temp FROM measurement;
DROP MEASUREMENT measurement;
SELECT value::integer INTO measurement FROM temp;
DROP MEASUREMENT temp;
如何在Flux 2中使用InfluxDB实现相同的操作?
InfluxDB 2有一个InfluxDB 1兼容层,但这不支持SELECT ... INTO ...子句:,因此必须使用新的查询语言Flux编写查询。
我正在使用influx -type=flux中的influxdb。
我已经在/etc/influxdb中的influxdb.conf文件中启用了flux。但是当我运行一个查询时,我得到了这个错误
from(bucket:"aayush_test/awesome_policy")
Error: unknown server error: 500 Internal Server Error
我使用的是influxdb version 1.7.8。请帮助我修复此错误
我有一个InfluxDB,我想连接到我的vue应用程序。我已经建立了到DB的连接,并且能够用下面的代码记录终端(而不是控制台)中的数据:
// index.js
import express from "express";
// These lines make "require" available
import { createRequire } from "module";
const require = createRequire(import.meta.url);
import store from '../store/in
我有kafka输入和输出主题。
我所做的是在主题A中编写,并希望在主题B中接收消息,但具有缓冲功能。
我的代码如下所示:
@Bean
public Function<Flux<String>, Flux<String>> stringFlow() {
return flux ->
flux.window(4)
.flatMap(m -> m);
}
输入主题:
A
A
B
输出主题:
A
% Reached end of topic test-topi
我正在尝试编写一个脚本来保存mqtt数据并将其发送到influxDB。我遇到的问题是mqtt-paho模块的回调函数一直给出错误:AttributeError: 'Client' object has no attribute 'write_api'。我认为这是因为mqtt-paho的内部“Client”类中的self。我的完整脚本可以在下面找到: # Imported modules
# standard time module
from datetime import datetime
import time
# InfluxDB specific mo
我有一个用于流的Flux生成器(来自项目反应堆),它延迟1秒来释放每个元素。由于流是无限的,所以我也决定使用take()方法要使用多少个元素。我想测试这样的方法是否可以在给定的时间内执行。我试图创建我的解决方案,但没有成功。
这是Flux方法
import reactor.core.publisher.Flux;
import java.time.Duration;
@Slf4j
public class FluxAndMonoStreams {
public Flux<Double> createFluxDoubleWithDelay(long numberOfEleme
一旦安装了InfluxDB,2它就会出现一个包含各种语言示例代码的网站。在创建了具有RW权限的桶和令牌并选择了它们之后,就可以使用具有适当魔法字符串的代码片段了。把它们放在一起,我有一个:
using System;
using System.Threading.Tasks;
using InfluxDB.Client;
using InfluxDB.Client.Api.Domain;
using InfluxDB.Client.Writes;
namespace gen
{
class Program
{
static async Task Main(string[] ar