@@ -383,6 +383,25 @@ async def test_query_exception_propagation(self):
383
383
await self .client .query_api ().query ("buckets()" , "my-org" )
384
384
self .assertEqual ("unauthorized access" , e .value .message )
385
385
386
+ @async_test
387
+ @aioresponses ()
388
+ async def test_parse_utf8_two_bytes_character (self , mocked ):
389
+ await self .client .close ()
390
+ self .client = InfluxDBClientAsync ("http://localhost" )
391
+
392
+ body = '''#group,false,false,false,false,true,true,true
393
+ #datatype,string,long,dateTime:RFC3339,string,string,string,string
394
+ #default,_result,,,,,,
395
+ ,result,table,_time,_value,_field,_measurement,type
396
+ '''
397
+ for i in range (1000 ):
398
+ body += f",,0,2022-10-13T12:28:31.{ i } Z,ÂÂÂ,value,async,error\n "
399
+
400
+ mocked .post ('http://localhost/api/v2/query?org=my-org' , status = 200 , body = body )
401
+
402
+ data_frame = await self .client .query_api ().query_data_frame ("from()" , "my-org" )
403
+ self .assertEqual (1000 , len (data_frame ))
404
+
386
405
async def _prepare_data (self , measurement : str ):
387
406
_point1 = Point (measurement ).tag ("location" , "Prague" ).field ("temperature" , 25.3 )
388
407
_point2 = Point (measurement ).tag ("location" , "New York" ).field ("temperature" , 24.3 )
0 commit comments