influxdata / influxdata/influxdb-client-python
Performance bottleneck in FluxCsvParser when parsing large CSV payloads (10MB+)
Personne n'a encore pris cette issue.
- Langage dominant
- Python
- Étoiles
- 793
- Forks
- 186
- Merge moyen
- 3 h 2 min
- PR mergées (30 j)
- 1
Description
### Specifications
* Client Version: 1.48.0
* InfluxDB Version: 2.7
* Platform: macos
### Code sample to reproduce problem
```python
```
import influxdb_client
client = influxdb_client.InfluxDBClient(
url="http://localhost:8086",
token="TOKEN",
org="organization",
)
query_api = client.query_api()
query = 'from(bucket: "sensors") |> range(start: 2025-04-13T14:18:11.036Z, stop: 2025-04-13T14:33:11.036Z)'
result = query_api.query(org="matna", query=query)
### Expected behavior
runtime of this query must be same as ui influx
### Actual behavior
runtime this code is not same order
### Additional info
Hi InfluxDB team,
I've encountered a significant performance bottleneck in the FluxCsvParser class within the InfluxDB Python client when working with larger datasets.
🐞 Issue Description
When querying data (~10MB in size), the network call returns results in under 20 ms, which is excellent. However, the CSV parsing step takes over 5 seconds to complete. This introduces an unacceptable latency for high-throughput or low-latency use cases.
In contrast, using the Go client for the same query and dataset, the full query—including parsing—is completed in under 200 ms. This makes the Python client around 25x slower just in the parsing stage.
📈 Performance Benchmark
Data size: ~10MB (Flux CSV)
Query response time (network): < 20 ms
Parsing time (Python client): > 5000 ms
Parsing time (Go client): < 200 ms
🔍 Root Cause
Profiling indicates that the performance degradation is centered in the FluxCsvParser implementation. The current parsing logic in Python seems to be inefficient for large responses due to overhead in string parsing, tokenization, and possibly memory management.
💡 Suggested Improvement
To address this, I suggest reviewing the implementation of FluxCsvParser—specifically around how it handles tokenization, buffering, and line-by-line parsing. Additionally, performance could be dramatically improved by offloading the CSV parsing to a C extension (e.g., using cffi, cython, or ctypes) or integrating an existing optimized parser like libcsv or simdjson.
This would help close the gap with the Go client's performance while maintaining compatibility with the current interface.
✅ Request
Could the maintainers review the FluxCsvParser code path, especially in generate function?
Is there openness to rewriting this part as a performance-critical native extension, or at least modularizing it for optional native acceleration?
Guide de contribution
Aucun guide de contribution indexé pour ce dépôt
Par où commencer
- Lisez l'issue en entier, puis le guide de contribution du projet.
- Signalez en commentaire que vous la prenez — cela évite que deux personnes fassent le même travail.
- Forkez le dépôt et travaillez sur une branche.
- Ouvrez une pull request qui référence le numéro de l'issue.
Piste de recherche
Commencez par localiser l’implémentation de FluxCsvParser et sa fonction generate, puis profilez l’analyse séparément de la requête réseau à l’aide d’une réponse Flux CSV d’environ 10MB. Comparez le temps d’analyse de Python avec le résultat signalé du Go-client et identifiez les coûts liés à la tokenisation, à la mise en mémoire tampon ou au traitement des lignes. Le travail sera considéré comme terminé lorsqu’une amélioration mesurée de l’analyse aura été obtenue, que l’interface actuelle du client aura été préservée et que la comparaison des performances aura été documentée.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
Évaluation
- Stack technique
- python
- Domaine
- performance
- Type d'issue
- Bug
- Difficulté
- 5/5
- Temps estimé
- Plus d'une semaine
- Activité
- À l'abandon
- Clarté
- Plutôt claire
- Accessibilité débutants
- 25/100