1

I have a quite concerning problem with this API. I am using this API to perform six different queries one after the other. However the between the queries I save the resulting pandas dataframes into csv files.

After this phase, I proceed to read the csv files and perform some operations (I substitute the NaN values with 0 in the column called '_value'). The problem is that, in some executions of the code, the csv files seems to miss some columns or are not filled. It returns the following error:

Traceback (most recent call last):
  File "Path\code.py", line 136, in <module>
    fd['_value'] = fd["_value"].fillna(0)
  File "Path\Anaconda3\envs\tf\lib\site-packages\pandas\core\frame.py", line 3505, in __getitem__
    indexer = self.columns.get_loc(key)
  File "Path\Anaconda3\envs\tf\lib\site-packages\pandas\core\indexes\base.py", line 3631, in get_loc
    raise KeyError(key) from err
KeyError: '_value'
Exception ignored in: <function InfluxDBClient.__del__ at 0x000002723CB52170>
Traceback (most recent call last):
  File "Path\Anaconda3\envs\tf\lib\site-packages\influxdb_client\client\influxdb_client.py", line 284, in __del__
  File "Path\Anaconda3\envs\tf\lib\site-packages\influxdb_client\_sync\api_client.py", line 84, in __del__
  File "Path\Anaconda3\envs\tf\lib\site-packages\influxdb_client\_sync\api_client.py", line 661, in _signout
TypeError: 'NoneType' object is not callable
Exception ignored in: <function ApiClient.__del__ at 0x000002723CB53BE0>
Traceback (most recent call last):
  File "Path\Anaconda3\envs\tf\lib\site-packages\influxdb_client\_sync\api_client.py", line 84, in __del__
  File "Path\Anaconda3\envs\tf\lib\site-packages\influxdb_client\_sync\api_client.py", line 661, in _signout
TypeError: 'NoneType' object is not callable

I don't know how to solve this problem and why sometimes occurs and why sometimes not. Below you can see the code for which I do the queries.


from influxdb_client import InfluxDBClient

client = InfluxDBClient(
   url=url,
   token=token,
   org=org
)

query_api = client.query_api()

df = query_api.query_data_frame(query_1)
df.to_csv('path_to_file/name1.csv')

df = query_api.query_data_frame(query_2)
df.to_csv('path_to_file/name2.csv')

df = query_api.query_data_frame(query_3)
df.to_csv('path_to_file/name3.csv')

df = query_api.query_data_frame(query_4)
df.to_csv('path_to_file/name4.csv')

df = query_api.query_data_frame(query_5)
df.to_csv('path_to_file/name5.csv')

df = query_api.query_data_frame(query_6)
df.to_csv('path_to_file/name6.csv')

client.close()

To write this code I followed the examples at GitHub Influxdb-Client Python: Queries with pandas dataframe

Should I do somenthing like: open the client -> query -> save file -> close the client -> repeat?

EDIT: open the client -> query -> save file -> close the client -> repeat, did not solve anything.

Improve this question
2
  • Are you sure all queries are running successfully? Looks like some queries failed Commented Nov 17, 2022 at 15:27
  • Yes, I am sure, the query I use ask for data collected by some sensors between 4 am and 2 pm of the previous day (and I also have the option createEmpty = true in case some values are missing), so they should exist. MOreover, if I use these queries in Influxdb UI they always work correctly. Furthermore, when I run this code sometimes it works (not always). Therefore, I think it is something related to the client but I am not sure. Commented Nov 18, 2022 at 9:57
Related questions
1
Influxdb read/write operations
5
How to write into influxdb using line Protocol with Python
2
Inserting data into Influxdb using Python client with Line protocol
Load 7 more related questions Show fewer related questions

0

Reset to default

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.