我想改为在Influx Line Protocol (ILP)中输出指标,但micronaut-micrometer项目目前没有提供Influx注册表。我尝试通过导入io.micrometer:micrometer-registry-influx依赖项并手动配置InfluxMeterRegistry来解决此问题: @Factory return Duration.ofSeconds(10); public
在订阅者中,我正在获取消息并将值写入influxdb。在大约2000条记录之后,MQTT订阅者暂停并等待time.sleep()完成。client.write_api(write_options=SYNCHRONOUS)#Function to write the record to influxdef update_db(point): write_api.write(bucket=bucket, record=point)
print("