optimisation lecture fichier .txt

Bonjour,
Dans le cadre d'un développement d'extension QGIS (Python 2.7, librairies PyQt4), j'ai besoin de lire plusieurs (essentiellement 2) énormes fichiers .txt (environ 140 Mo) pour les intégrer dans une base de données.
Voici le code utilisé:

Code:

---

1 2 3 4 5

fichier = open(unicode(pathFichier), "r") for ligne in fichier: ligne = ligne.decode('utf8') chaines = ligne.split(";") """ puis traitement des différents éléments de chaines"""

---

Y aurait il une possibilité moins gourmande en temps? J'ai cru comprendre que Python mettait déjà le fichier en mémoire cache lorsque qu'il l'ouvre dans "fichier".
Comment optimiser la lecture pour un très gros fichier?

Merci.

Salut,

Citation:

---

Envoyé par maudJ

Bonjour,
Y aurait il une possibilité moins gourmande en temps?

---

Une première possibilité serait de mettre chaque ligne de ton fichier dans une liste ou dans un dictionnaire.
Pour choisir entre liste ou dictionnaire, faudrait savoir ce que tu traite comme données.
Ensuite tu parcours cette liste ou ce dico pour traiter tes chaines.

Citation:

---

Comment optimiser la lecture pour un très gros fichier?
Je pense que cela dépend de tes données.

---

Dans des cas que j'ai traités avec des fichiers de plus centaines de milliers de lignes, je transférais tout mon fichier dans un tableau et ensuite je travaillais sur le tableau, alors qu'au départ je travaillais directement lignes par lignes depuis mon fichier, le temps c'est vue être diviser par 5.
Ensuite tout dépend également de la machine sur laquelle ton script va tourner, et si tu es en 32bits ou en 64bits.

Merci pour cette info. Voici le traitement que je fais des données:

Code:

---

1 2 3 4 5 6 7

#traitement if nbCh>=5 and self.verifTableGen(chaines[1], chaines[2]): if nbCh == 5: chaines.append(0) listDonnees.append((nbEnreg, chaines[1], chaines[2], chaines[3], chaines[4], chaines[5])) nbEnreg += 1

---

en gros je récupère des données que j'insère dans une liste pour former les valeurs nécessaire à l'insert de sqlite.
verifTableGen vérifie que les premières données sont bien dans la base de donnée. Le fichier fourni a chaque ligne commençant par un ; c'est pourquoi je commence à 1 la lecture.
Je pense que l'utilisation d'une liste serait mieux vu ce que j'en fais ensuite, non?

Citation:

---

Envoyé par maudJ

Merci pour cette info. Voici le traitement que je fais des données:
Je pense que l'utilisation d'une liste serait mieux vu ce que j'en fais ensuite, non?

---

C'est à vous de faire le test et constater s'il y a une amélioration ou pas.

Bonjour,

En principe, les ETL (logiciel couramment utilisé dans ce genre de tâches) ne mettent pas la totalité du fichier en mémoire. Ils travaillent par séquence (nombre de ligne), un peu comme du streaming, bout par bout. Par contre, cela n'est envisageable que si vous n'avez pas à faire de traitement bloquant sur vos données. Par exemple, si vous devez faire un tri ou une agrégation, obligatoirement vous devez récupérer la totalité des données.

Vous pourriez peut être envisager le traitement puis l'insertion des données à chaque ligne, en itérant notamment avec yield (générateur), cela résoudra vos problèmes de mémoire, un exemple ici : http://sametmax.com/comment-utiliser...urs-en-python/

Vous avez également deux articles sympathiques ici http://www.chicoree.fr/w/Lire_et_%C3...te_avec_Python et ici http://www.chicoree.fr/w/Fichiers_CSV_en_Python.

Avec sqlite, je ne sais pas, mais avec de vraies base de données, on peut faire des insertions en masse (bulk insert), par exemple pour sql server : https://msdn.microsoft.com/fr-fr/lib...=sql.120).aspx

Bonjour,
Merci pour ces réponses. Vu ce que je fais des données en fait le plus efficace serait d'importer directement un fichier csv dans ma table sqlite.
Problème: je suis en Python 2.7 et toutes les aides concernant cette manip indique python 3. Serait-ce qu'il n'est pas possible de le faire en Python 2.7?

Salut,

Citation:

---

Envoyé par maudJ

Merci pour ces réponses. Vu ce que je fais des données en fait le plus efficace serait d'importer directement un fichier csv dans ma table sqlite.
Problème: je suis en Python 2.7 et toutes les aides concernant cette manip indique python 3. Serait-ce qu'il n'est pas possible de le faire en Python 2.7?

---

"importer directement un fichier csv dans ma table sqlite" se fait avec des commandes du shell sqlite (pas besoin de Python)... poster au moins une URL qui décrit ce dont vous parlez aiderait à comprendre ce que vous racontez.

- W

En fait désolée, ce midi je n'avais pas les yeux en face des trous, j'ai lu python3 au lieu de SQLite3, du coup je ne comprenais pas...

Je cherche en fait à lire un fichier .csv ou .txt en python (extension QGIS) pour insérer les données dans une table spatialite (sqlite).
J'ai un fichier créé sous excel avec plusieurs lignes d'entête. Ensuite j'ai toutes les données, chaque ligne correspondant à une entrée de ma table, avec les champs séparés par un ";" et le début de ligne commençant également par un ";".

Citation:

---

;1;8;0.680000;15.250000

---

Il y a 1 047 494 lignes et 5 colonnes dans le fichier.
Lorsque je lis le fichier en entier, ça plante, c'est trop lourd. Les deux autres possibilités (ligne par ligne avec "readline" ou en utilisant l'objet fichier), ça va mais je dois vider régulièrement la liste utilisée pour insérer les données dans sqlite sinon problème de mémoire.
et c'est extrêmement long et laborieux.

J'ai lu avec intérêt les liens et conseils fournis et me suis penchée sur la question du bulkinsert dont parle Patic.
en sqlite il y a un executemany dont je me servais déjà et qui ne pose pas de problème.

Mais le problème reste le stockage de ces données entre la lecture et l'envoi à la base sqlite.
J'ai trouvé des docs proposant de charger directement un fichier csv dans une base sqlite avec un dicreader():

https://stackoverflow.com/questions/...e-using-python

mais finalement ils stockent également les données à intégrer.
L'idée d'envoyer des données avec un yield (donc sans enregistrer) est intéressante, mais je ne peux alors pas les intégrer de manière optimisée dans la base SQLite.


Finalement, je vais rester sur une des deux options de départ: objet fichier ou lecture ligne par ligne, et vider régulièrement (tous les 100 000 lignes ) ma liste d'insertion de données sqlite.

Merci pour votre aide et désolée pour le message farfelu et inutile d'heure de déjeuner (mon cerveau fonctionne moins bien quand il crie famine!)

Avez-vous lu la réponse de wiztrick ? Si oui, il me semble que vous n'avez pas compris, car votre réponse est incohérente par rapport à sa proposition. Pourquoi faire du contre productif alors qu'avec une simple commande sqlite, vous créez rapidement votre base ?

Oui j'ai bien compris, mais je ne peux pas faire lancer une commande dans le shell à l'utilisateur à chaque lancement de l'extension, au moment où j'en ai besoin pour faire les calculs suivants, c'est pourquoi je passe par le langage python. A moins que je puisse lancer directement la console shell et les commandes qui vont avec depuis mon extension? Je n'ai pas trouvé.

En fait, avant de remplir cette table X, il faut déjà que j'en remplisse une autre Y, par un autre biais, qui possède des données en lien avec les clés secondaires de la table remplie grâce au fichier.
Et l'utilisateur ne lance que l'extension avec les adresses des fichiers en entrée et les fichiers shp chargés dans QGIS qui servent à alimenter les autres tables.

En gros:
1) je récupère toutes les infos en entrée (shp et fichiers txt)
2) je remplis les tables en lien avec les données vecteur (shp)
3) je remplis ma table à partir du fichier txt
4) je fais mon traitement pour lier le tout, sortir ce que je veux et afficher le résultat en shp
ensuite je vide toutes les tables. L'utilisateur ne voit jamais la partie Base de données. Il n'a aucune manip à faire de ce côté là et les bases de données ne servent qu'à faire les traitements.

Il y a clairement des solutions adaptées, peut-être que le module pandas est ce qu'il vous faut, voir ICI. C'est une des meilleures solutions en ce qui me concerne. Il faudrait voir avec numpy aussi, module très performant.

Salut,

Citation:

---

Envoyé par maudJ

A moins que je puisse lancer directement la console shell et les commandes qui vont avec depuis mon extension? Je n'ai pas trouvé.

---

Vous pouvez toujours passer des commandes "shell" depuis Python grâce au module subprocess

Citation:

---

Envoyé par maudJ

En fait, avant de remplir cette table X, il faut déjà que j'en remplisse une autre Y, par un autre biais, qui possède des données en lien avec les clés secondaires de la table remplie grâce au fichier.
Et l'utilisateur ne lance que l'extension avec les adresses des fichiers en entrée et les fichiers shp chargés dans QGIS qui servent à alimenter les autres tables.

---

Déjà si vous arrivez à faire fonctionner votre truc, c'est déjà pas si mal.
Après, vous pouvez lancer l'opération en tâche de fond (et l'utilisateur attend que çà se termine en étant bloqué ou en faisant autre chose). Après pour aller plus vite, il faut découper les traitements en "blocks" (.readlines accepte un paramètre size qui permet de faire cela) et comme à priori vous faites beaucoup d'entrées-sorties disques, vous pouvez essayer de paralléliser un peu lectures, traitements, écritures dans la BDD avec des threads jusqu'à saturer ou occuper X % de la bande passante de vos disques (si vous saturez, les autres utilisateurs vont ramer...).

- W

Citation:

---

Envoyé par fred1599

Il y a clairement des solutions adaptées, peut-être que le module pandas est ce qu'il vous faut, voir ICI. C'est une des meilleures solutions en ce qui me concerne. Il faudrait voir avec numpy aussi, module très performant.

---

Oui, j'ai déjà été attirée à plusieurs reprises par ce module panda... Cependant, je pensais jusque là qu'il n'était pas compatible avec PyQGIS.
Je viens de trouver ceci
Je vais donc regarder de plus près. Sachant que je développe sous linux mais qu'ensuite j'installerai le tout sur du windows...

Je suis également en train d'étudier le module subprocess.
L'utilisateur est déjà bloqué pendant le traitement. J'avais regardé du côté des threads mais j'ai encore du mal à gérer le retour pour continuer avec une autre tâche et ne pas faire cette autre tâche avant que la lecture ne soit terminée. Enfin c'est un problème de structuration à ce niveau là. Il faut réussir à "voir" en parallèle et pas en série, et je n'y suis pas encore habituée, surtout que j'avais déjà structuré mon programme avant de connaître les threads. J' étudie tout ça . merci.
Je reviendrai quand j'aurai réussi au moins une solution.

Bon, voilà où j'en suis: installation de pandas, (sous linux c'est direct dans le bon dossier) puis :

Code:

---

1 2 3

df = pandas.read_csv(pathFichier, sep = ';', names = ['vide', champs1, champs2, champs3, champs4], skiprows = [0, 1, 2, 3, 4, 5, 6, 7]) # ne lit pas l'entête du fichier del df['vide'] # la colonne est vide df.to_sql('liaison_gen', self.connectionBD, if_exists='append', index=False) # transfère le contenu du fichier dans la table

---

C'est simple, efficace et bien plus rapide et moins gourmand que la méthode de lecture par lignes.
Étant donné la lourdeur des données et des traitements, je trouve que c'est plutôt concluant! Reste à tester sur windows pour être sure.

Bon et bien le test sous windows n'est pas concluant. Sur deux pc différents j'ai des memory error au niveau de l'appel de la fonction pandas.
Donc je vais tester par la console directement avec le module subprocess (solution proposée par wiztricks).
Sinon je retournerai lire ligne par ligne... au moins ça fonctionnait, lentement mais sûrement!
Je vous tiens au courant.

Bonjour,
Alors je suis en traint d'étudier subprocess et les commandes shell de sqlite.
Je suis face à une incompréhension mais je ne sais pas s'il faut que je crée un autre sujet ailleurs pour ça et si c'est dans python ou sqlite...
Voilà le soucis:
Je crois avoir compris que je devais faire un

Code:

---

subprocess.Popen()

---

et un

Code:

---

Popen.communicate()

---

Là où ça se corse c'est pour les arguments.
Dans le cas où je crée un script que j'appelle scriptImport.sqlite:
mon script:

Code:

---

1 2 3

.mod csv .separator ; .import fichier nomtable

---

et là justement comment je fais pour passer le nom du fichier en variable?

Ensuite je dois faire mon subprocess:

Code:

---

1 2	arg = "sqlite nomBdd.sqlite '.read'" subprocess.Popen(arg, stdin = scriptImport.sqlite')

---

Là plusieurs choses me chagrinent: les cotes de chaine de caractère, le fichier en entrée alors que la commande commence par sqlite3... Va t'il comprendre que c'est pour le read?
Je pensais utiliser les caractère %s pour dans le script sql, mais je ne sais toujours pas comment intégrer ensuite ma variable...

Sinon j'ai trouvé ça
ce qui m'a imspiré quelque chose du genre:

Code:

---

1 2 3

command = "sqlite3 %s 'read %s' "% (DatabaseName, FileName) DumpProc = subprocess.Popen(command)

---

mais j'ai toujours ce problème de nom du fichier csv en entrée à passer en variable.
J'espère avoir été assez claire dans mon incompréhension...
Merci.

Salut,

Pourquoi ne pas créer un fichier machin.sqlite avec les commandes souhaitées puis passer la commande "sqlite machin.sqlite" à Popen?

- W

Oui, ça résoudrait le problème des cotes mais il restera quand même le problème de la variable du nom de fichier à lire, non?

Citation:

---

Envoyé par maudJ

Oui, ça résoudrait le problème des cotes mais il restera quand même le problème de la variable du nom de fichier à lire, non?

---

Puisque vous fabriquez vous même le fichier "machin.sqlite", vous pouvez y écrire ce que vous voulez dedans et ce sont juste des chaînes de caractères.
Si on peut de:

Code:

---

1 2 3

.mod csv .separator ; .import fichier nomtable

---

C'est pas compliqué d'en faire une chaine de caractères:

Code:

---

1 2 3

data = '''.mod csv .separator ; .import fichier nomtable'''

---

puis de mettre en variables les éléments "intéressants":

Code:

---

1 2 3

data = '''.mod csv .separator ; .import %(fichier)s %(nomtable)s'''

---

qu'on remplace avec le contenu de n'importe quel dico:

Code:

---

1 2 3 4 5

>>> fichier = 'XXX' >>> nomtable = 'ZZZZ' >>> data % vars() '.mod csv\n.separator ;\n.import XXX ZZZZ' >>>

---

- W

Oui en fait il me manquait la méthode pour remplaçait par des variables dans la chaîne de caractère (avec %(nomVariable)s )
Ceci dit j'aurais pu faire aussi

Code:

---

1 2	chaine = "le début de ma chaine" + variable + "suite de ma chaine".

---

Mais il faut dire que je n'avais pas pensé écrire dans un fichier à chaque fois, j'étais restée figée sur comment lire un fihcier déjà écrit. Il m'a manqué la petite "étincelle"!
Merci. je vais voir de ce côté là.

alors j'ai essayé plusieurs commandes différentes. Aucune erreur, mais rien ne se passe... Je viens donc de faire une simple création de table dans ma base de données:

Code:

---

1 2 3

args = ["sqlite3",DatabaseName,"CREATE TABLE my_table(un TEXT, deux TEXT, trois TEXT, quatre TEXT, cinq TEXT, six TEXT);",] subprocess.call(args, shell=True)

---

Et là pas de table créée. mais toujours pas de message d'erreur.
DatabaseName est une variable contenant l'adresse complète du fichier de la base sqlite.
Je précise au cas où que je suis sous linux.
Pour lancer une commande sqlite je dois me mettre, depuis la console, dans le répertoire python2.7. Ensuite l'entrée manuelle des commandes précédentes fonctionnent correctement.
A savoir :

Code:

---

1 2 3

sqlite3 mabase.db CREATE TABLE my_table(un TEXT, deux TEXT, trois TEXT, quatre TEXT, cinq TEXT, six TEXT);

---

Me crée bien une table dans ma base de données.
Pourquoi cela ne fonctionne t il pas depuis le subprocess? Faut il lui spécifier l'endroit ou se trouve sqlite 3?

Salut,

Citation:

---

Envoyé par maudJ

Pourquoi cela ne fonctionne t il pas depuis le subprocess? Faut il lui spécifier l'endroit ou se trouve sqlite3?

---

Lancez la console Python et jouez avec:

Code:

---

1 2	>>> from subprocess import call >>> args = [ "sqlite3", "test.dat", "create table test (a text);" ]

---

Puis vous regardez ce que çà sort avec:

Code:

---

1 2	>>> call(args, shell=True) >>> call(args, shell=False)

---

- W

Super merci! Ca m'a permis de comprendre et de faire mon code.
Pour les essais j'ai mis dans une table temporaire, mais je vais modifier pour importer directement dans la table et nettoyer ensuite les données qui ne vont pas (entêtes et première colonne), ce qui fera moins de traitement supplémentaire qu'une copie de table. Il ne me reste plus qu'à calculer le temps gagné ou pas... En tout pas au niveau ressources c'est clair que ça en prend moins que toutes les solutions testées précédemment.

Je passe en résolu.

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14

# écriture dans le fichier script de la commande d'importation pathScript = self.pathDir + '/Donnees/script.sqlite' data = ".mod csv\n.separator ;\n.import " + pathFichier + " table_tmp" fichier = open(pathScript,"w") fichier.write(data) fichier.close() # création d'une table temporaire pour l'importation args = [ "sqlite3", self.pathBD, "create table IF NOT EXISTS table_tmp (un text, deux text, trois text, quatre float, cinq float, six float);" ] proc=subprocess.Popen(args, shell=False) proc.wait() # commande d'exécution du script d'importation args = [ "sqlite3", self.pathBD, ".read "+ pathScript ] proc=subprocess.Popen(args, shell=False) proc.wait()

---

Pour info, avec le clock, je trouve 4.73631 s de traitement avec la nouvelle solution (subprocess) contre 39.090568 s avec la lecture ligne par ligne.
Y a pas photo c'est efficace!