class_docstr: Interact with InfluxDB.
  
  Performs a connection to InfluxDB and retrieves client.
  
  :param influxdb_conn_id: Reference to :ref:`Influxdb connection id <howto/connection:influxdb>`.
class_docstr_tok: ["Interact","with","InfluxDB",".","Performs","a","connection","to","InfluxDB","and","retrieves","client",".",":","param","influxdb_conn_id",":","Reference","to",":","ref",":","`","Influxdb","connection","id","<","howto\/connection",":","influxdb",">","`","."]
docstr: Run the query and return a pandas dataframe.
  
  Note: The bucket name should be included in the query.
  
  :param query: InfluxDB query
  :return: pd.DataFrame
docstr_tok: ["Run","the","query","and","return","a","pandas","dataframe",".","Note",":","The","bucket","name","should","be","included","in","the","query",".",":","param","query",":","InfluxDB","query",":","return",":","pd.DataFrame"]
code: def query_to_df(self, query) -> pd.DataFrame:
      """Run the query and return a pandas dataframe.
  
      Note: The bucket name should be included in the query.
  
      :param query: InfluxDB query
      :return: pd.DataFrame
      """
      client = self.get_conn()
  
      query_api = client.query_api()
      return query_api.query_data_frame(query)
  
file_path: airflow/airflow/providers/influxdb/hooks/influxdb.py
imports: from __future__ import annotations
  from typing import TYPE_CHECKING
  from influxdb_client import InfluxDBClient
  from influxdb_client.client.write.point import Point
  from influxdb_client.client.write_api import SYNCHRONOUS
  from airflow.hooks.base import BaseHook
label_desc: Use image node_id 6 for calling the InfluxDBHook obj's underlying member method code with example usage: obj.query_to_df(query) and returns: query_api