Varje mappare behöver sin egen databasanslutning. Skapa databasanslutningen i mapper_init() och stäng den i mapper_final() . Du måste skapa databasen separat från mrjob-skriptet. Du bör prova några mycket enkla mrjob-skript först. Du har inte startat det på rätt sätt. Arbeta igenom exemplen i dokumentationen.
