flask 使用 influxdb

Flask是一个轻量级的Web应用框架，而InfluxDB是一个分布式、时间序列数据库，特别适合存储和查询大量的测量数据，例如监控系统中的数据。要在Flask应用程序中集成InfluxDB，你可以按照以下步骤操作：

1. 安装依赖：
首先，你需要安装Flask和InfluxDB客户端库。使用pip安装：

   pip install Flask influxdb

2. 设置配置：
在你的Flask应用中，添加InfluxDB的相关配置，比如主机名、端口、数据库名等，通常会放在app.py或config.py文件中：

   from influxdb import InfluxDBClient

   INFLUX_DB_CONFIG = {
       'host': 'localhost', 
       'port': 8086, 
       'dbname': 'your_database_name',
       'username': 'root',
       'password': 'your_password'
   }
   client = InfluxDBClient(**INFLUX_DB_CONFIG)

3. 创建数据写入方法：
在Flask路由处理程序中，创建一个函数用于将数据推送到InfluxDB：

   @app.route('/data', methods=['POST'])
   def save_data():
       measurement = request.form.get('measurement')
       fields = request.form.to_dict()
       tags = {'tag_key': request.form.get('tag_value')}
       client.write_points([Point(measurement, fields, tags)])
       return 'Data saved successfully.'

4. 数据读取和查询：
如果你想从InfluxDB查询数据并展示到前端，可以使用`influxdb-client`提供的query功能。

5. 示例运行：
假设你有一个简单的HTML表单供用户提交数据，你可以这样处理POST请求：

   <form method="post" action="/data">
     Measurement: <input type="text" name="measurement"><br>
     Field data (key-value pairs): <input type="text" name="field1"><br>
     Tag value: <input type="text" name="tag_value"><br>
     <input type="submit" value="Submit">
   </form>

记得根据实际需求调整代码，如认证、错误处理以及更复杂的查询逻辑。