Foro - Perl en Español

por **damian1510** » 2013-01-07 15:30 @688

Hola, estoy teniendo problemas con un script que es una especie de dæmon, en el cual se crean varios procesos que hacen diferentes acciones en una BD MySQL. El tema es que los resultado resultan ilógicos, o "explota".

Resumiendo, el programa sería básicamente esto:

Sintáxis: [ Descargar ] [ Ocultar ]

Using perl Syntax Highlighting

...;

while(1){

my$child_id=fork();
if($child_id){
...
}
else{
# Se ejecutan varios módulos según parámetros en paralelo que acceden a la BD
# (consultas, updates, etc.)
}
}Coloreado en 0.002 segundos,  usando GeSHi 1.0.8.4

Tengo una clase que se encarga de conectarse a la BD y ejecutar las queries. Algunas funciones son estas:

Sintáxis: [ Descargar ] [ Ocultar ]

Using perl Syntax Highlighting

sub connect {
    my $self = shift;
 
    $dsn = "DBI:mysql:database=$self->{database};host=$self->{host};port=$self->{port}";
 
    return $db if defined $db;
 
    $db = DBI->connect( $dsn, $self->{user}, $self->{password}, { RaiseError => 1 } );
 
    $db->{mysql_auto_reconnect} = 1;
    $db->{InactiveDestroy}      = 1;
    $db->{'AutoCommit'}         = 1;
    return $db;
}
 
sub executeSQLUpdate {
    my $self = shift;
    my $sql  = shift;
 
    my $mySQL = $db->prepare($sql) or print "Error en prepare $sql" . $db->errstr;
 
    $mySQL->execute() or print "Error en execute '$sql' \n ";
    $mySQL->finish();
    return;
}
 
sub getValue {
    my $self = shift;
    my $sql  = shift;
 
    $self->connect();
    my $mySQL  = $db->prepare($sql) or print "Error en prepare $sql" . $db->errstr;
    my $result = $mySQL->execute()  or print "can't execute the query: " . $mySQL->errstr;
 
    if ( $mySQL->rows == 0 ) {
        return undef;
    }
    else {
        my @element = $mySQL->fetchrow_array();
        return $element[0];
    }
}
Coloreado en 0.002 segundos,  usando GeSHi 1.0.8.4

¿Alguna idea de cómo puedo solucionar este tema?
¡Gracias!

Yo activaría todos los logs y pondría print() o say() por todas partes, para saber qué está haciendo el programa en cada momento. Y mirar el log de actividad de MySQL, por supuesto, para saber qué consultas se han hecho, y cómo.

Poco más se me ocurre viendo el código, ya que yo lo veo bien...

por **damian1510** » 2013-01-11 09:55 @455

¡Gracias! Eso lo venía haciendo y las consultas estaban bien, el error se genera porque al parecer la concurrencia le genera problemas a la BD, aunque esto no debería ocurrir.

Otra cosa que probé es de chequear las conexiones abiertas, pero parece está todo bien.
¿Hay algo que debería tener en cuenta y que se me esté pasando para trabajar con fork() en Perl y con el acceso al MySQL?

¡Se agradece cualquier sugerencia!
Saludos.

por **explorer** » 2013-01-11 23:39 @027

Pero, ¿qué problemas dice la base de datos que tiene?

¿Too many connections?

Por eso hay que ver los logs, para saber qué mensaje de error saca...

MySQL tiene una variable que indica el máximo número de conexiones simultáneas: max_connections, siendo su valor, por defecto, de 100. ¿Cuántas conexiones simultáneas pretendes hacer?

Tampoco sé a qué te refieres con la expresión "el programa explota". ¿Quieres decir que el programa Perl termina con un mensaje de error? ¿Cuál?

Otra cosa... cuando se accede a la base de datos, ¿en dónde se hace el bloqueo? Si suponemos que solo se hacen SELECT, no importa, pero si se hacen INPUT o UPDATE, la base de datos bloqueará la tabla o el registro, y durante ese tiempo, no podrá acceder nadie más.

En caso de bloquear por tabla, te recomiendo que leas la página de manual de DBD::mysql, la sección sobre mysql_auto_reconnect, ya que comenta que no es recomendable.

Atento a lo que dice el manual de DBI sobre InactiveDestroy: en un proceso con fork(), o bien el padre o bien el hijo, debe tener marcada esta acción, PERO no ambos, en todos los handles que compartan. Según el código de connect(), así debería ser...

En esa misma sección te dan una pista para realizar la traza de un proceso con fork(): aumentando el nivel de trace de DBI a 9. Cada hijo se mostrará con su correspondiente id (buscar "trace" en el manual).

por **damian1510** » 2013-02-19 07:16 @344

Hola, gracias por la ayuda. Después de un tiempo seguí con esto. El problema era que cuando se creaban los hijos y terminaban quedaban en <defunc>. La solución fue agregarle antes del while()

$SIG{CHLD} = 'IGNORE';

Ahora ya no tengo más problemas.

¡Saludos!

Foro - Perl en Español

Concurrencia y consultas a MySQL

Concurrencia y consultas a MySQL

Publicidad

Re: Concurrencia y consultas a MySQL

Re: Concurrencia y consultas a MySQL

Re: Concurrencia y consultas a MySQL

Re: Concurrencia y consultas a MySQL

¿Quién está conectado?