python-3.x - 将 Pandas Dataframe 放入 influxDB

Question

我想把这个 DataFrame ( DataFrame ) 放到 influxdb 中。不幸的是，我收到以下错误消息：“ValueError：DataFrame 的真值不明确。使用 a.empty、a.bool()、a.item()、a.any() 或 a.all()。”

这两条线有问题吗？

• 标签 = { 'tag1': df[['tag1']], 'tag2': df[['tag2']] }

• client.write_points(df, 'test', tags = tags)

  我不懂为什么。谢谢您的帮助

     def main(host='10.0.0.3', port=8086):
          """Instantiate the connection to the InfluxDB client."""
      user = ''
      password = ''
      dbname = 'ess_2'
      protocol = 'line'
  
      client = DataFrameClient(host, port, user, password, dbname)
  
      print("Create database: " + dbname)
      client.create_database(dbname)
  
      t = time.strftime('%Y-%m-%d %H:%M:%S')
      headers = ['time','tag1','tag2','field1','field2']
      data    = [[t,'MSFT','NYSE',1.3,2.5],[t,'APPL','NYSE',3.5,4.24]]
      df      = pd.DataFrame(data, columns = headers)
      df['time'] = pd.to_datetime(df['time'])
      df      = df.set_index('time')
      tags        = { 'tag1': df[['tag1']], 'tag2': df[['tag2']]  }   #DEBUG
      client.write_points(df, 'test', tags = tags) #DEBUG
  
  
  
      print("Read DataFrame")
      client.query("select * from demo")
  
  
  def parse_args():
      """Parse the args from main."""
      parser = argparse.ArgumentParser(
          description='example code to play with InfluxDB')
      parser.add_argument('--host', type=str, required=False,
                          default='10.0.0.3',
                          help='hostname of InfluxDB http API')
      parser.add_argument('--port', type=int, required=False, default=8086,
                          help='port of InfluxDB http API')
      return parser.parse_args()
   if __name__ == '__main__':
       args = parse_args()
       main(host=args.host, port=args.port)
  

标签： python-3.xpandasdataframetime-seriesinfluxdb