Jeder Mapper benötigt eine eigene Datenbankverbindung. Erstellen Sie die Datenbankverbindung in mapper_init() und schließen Sie es in mapper_final() . Sie müssen die Datenbank separat vom mrjob-Skript erstellen. Sie sollten zuerst einige sehr einfache mrjob-Skripte ausprobieren. Du hast es nicht richtig gestartet. Arbeiten Sie die Beispiele in der Dokumentation durch.
