Chaque mappeur a besoin de sa propre connexion à la base de données. Créez la connexion à la base de données dans mapper_init()
et fermez-le dans mapper_final()
. Vous devez créer la base de données séparément du script mrjob. Vous devriez d'abord essayer quelques scripts mrjob très simples. Vous ne l'avez pas démarré de la bonne façon. Parcourez les exemples de la documentation.