Discussion :

[jfmerveille]

Bonjour,

Je souhaite développer un programme en PERL qui traitera (opérations sur les enregistrements) une liste de fichiers en entrée :
- sous la forme d'un démon Unix afin de traiter les fichiers en fil de l'eau
- sur plusieurs processus afin de traiter des fichiers en parallèle

J'ai trouvé quelques exemples sur le Net; avec utilisation de Proc:ID_File and Proc:aemon. Mais impossible de les valider; Proc:ID_File "not found sur le site http://search.cpan.org" !

Comment faire ce petit programme : la méthode ou un exemple serait bienvenu ?

Pourquoi en PERL ?, car les fichiers sont très volumineux et j'ai beaucoup d'opérations à réaliser sur les fichiers de sortie.

Environnement : Debian / Perl 5.10

D'avance merci pour votre aide

[Lolo78]

Ce ne serait pas plutôt:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

Proc::Pidfile

ou encore

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

Proc::PID::File

Jette un coup d’œil ici:

http://cpan.uwinnipeg.ca/htdocs/Proc...idfile.pm.html

ou là:

http://search.cpan.org/dist/Proc-PID-File/File.pm

[Philou67430]

Je souhaite développer un programme en PERL qui traitera (opérations sur les enregistrements) une liste de fichiers en entrée :
- sous la forme d'un démon Unix afin de traiter les fichiers en fil de l'eau
- sur plusieurs processus afin de traiter des fichiers en parallèle

Je n'ai pas compris : tu souhaites utiliser l'une OU l'autredes alternatives, ou bien l'une ET l'autre ?

As-tu aussi regardé du coté des threads (use thread) ?
et de Proc::Daemon

[jfmerveille]

Bonjour,

J'ai revu la solution technique :
- Abandon du daemon Unix
- Pour le multi-process, j'ai utilisé le module [Parallel::ForkManager]

Extrait du code

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
use Parallel::ForkManager;
 
# Paramètrage du module [Parallel::ForkManager] sur actions de START, WAIT et FINISH, sur action de répartition
$pm->run_on_finish(
	sub { my ($pid, $exit_code, $ident) = @_;
	#print "***** [INFO3] : Traitement du fichier $ident terminés ".
	#"sur le PID $pid avec Exit Code: $exit_code\n";
	}
);
$pm->run_on_start(
	sub { my ($pid,$ident)=@_;
	#print "***** [INFO3] : Traitement du fichier $ident, sur PID: $pid\n";
	}
);
$pm->run_on_wait(
	sub {
	#print "***** [INFO3] : Attente la fin des processus fils ...\n"
	},100
);
 
@fichiers = glob($data_in_ready . "*.cdr");
foreach my $fichiers (@fichiers) 
{
	# Fork
	my $pid = $pm->start($fichiers) and next;
	# Fonction traitant les fichiers en entrée		
	traitement_fichier_entree($fichiers);
	$pm->finish;
}
# Attente de tous les sous-processus avant de continuer
$pm->wait_all_children;

Merci pour votre aide