Cada mapeador precisa de sua própria conexão de banco de dados. Crie a conexão do banco de dados em
mapper_init()
e feche-o em mapper_final()
. Você precisa criar o banco de dados separadamente do script mrjob. Você deve tentar alguns scripts mrjob muito simples primeiro. Você não começou da maneira correta. Trabalhe com os exemplos na documentação.