Dobrica Pavlinušić's random unstructured stuff: Gearman
https://saturn.ffzg.hr/rot13/
2010-05-04T10:02:46Z
Gearman
<div>Creator: Dobrica Pavlinušić</div><hr/><div>Tags: gearman</div><hr/><div class="wiki">
<div class="nlw_phrase"><table class="wafl_container">
<tr>
<td>
<div class="wafl_box">
<div class="wafl_titlebox">
<div class="wafl_title">
Contents: [Dobrica Pavlinušić's random unstructured stuff]
</div>
</div>
<div class="wafl_items">
<div class="wiki">
<ul>
<li><span class="nlw_phrase"><a title="section link" href="https://saturn.ffzg.hr/rot13/index.cgi?dobrica_pavlinu%C5%A1i%C4%87_s_random_unstructured_stuff#links">Dobrica Pavlinušić's random unstructured stuff (Links)</a><!-- wiki: {link: [Dobrica Pavlinušić's random unstructured stuff] Links} --></span></li>
<ul>
<li><span class="nlw_phrase"><a title="section link" href="https://saturn.ffzg.hr/rot13/index.cgi?dobrica_pavlinu%C5%A1i%C4%87_s_random_unstructured_stuff#implementations">Dobrica Pavlinušić's random unstructured stuff (Implementations)</a><!-- wiki: {link: [Dobrica Pavlinušić's random unstructured stuff] Implementations} --></span></li>
<li><span class="nlw_phrase"><a title="section link" href="https://saturn.ffzg.hr/rot13/index.cgi?dobrica_pavlinu%C5%A1i%C4%87_s_random_unstructured_stuff#documentation">Dobrica Pavlinušić's random unstructured stuff (Documentation)</a><!-- wiki: {link: [Dobrica Pavlinušić's random unstructured stuff] Documentation} --></span></li>
</ul>
<li><span class="nlw_phrase"><a title="section link" href="https://saturn.ffzg.hr/rot13/index.cgi?dobrica_pavlinu%C5%A1i%C4%87_s_random_unstructured_stuff#cookbook">Dobrica Pavlinušić's random unstructured stuff (Cookbook)</a><!-- wiki: {link: [Dobrica Pavlinušić's random unstructured stuff] Cookbook} --></span></li>
</ul>
</div>
</div>
</div>
</td>
</tr>
</table>
<!-- wiki: {toc: }
--></div><br /><br /><h1 id="links">Links</h1>
<h2 id="implementations">Implementations</h2>
<ul>
<li><a target="_blank" title="(external link)" href="http://code.sixapart.com/trac/gearman">http://code.sixapart.com/trac/gearman</a></li>
<li><a target="_blank" title="(external link)" href="http://gearman.org/">http://gearman.org/</a></li>
</ul>
<h2 id="documentation">Documentation</h2>
<ul>
<li>protocol: <a target="_blank" title="(external link)" href="http://gearman.org/index.php?id=protocol">http://gearman.org/index.php?id=protocol</a></li>
<li>HTTP: <a target="_blank" title="(external link)" href="http://oddments.org/?p=68">http://oddments.org/?p=68</a></li>
</ul>
<h1 id="cookbook">Cookbook</h1>
<div class="nlw_phrase"><div class="fetchrss_box">
<div class="fetchrss_titlebox">
<div class="fetchrss_title">
<a href="http://sysadmin-cookbook.rot13.org/#gearman">Sysadmin Cookbook :: gearman</a>
</div>
</div>
<ul class="fetchrss_items">
<li class="fetchrss_item">
<a href="http://sysadmin-cookbook.rot13.org/#gearman">gearman</a>
<p class="fetchrss_description">
<h4>0.install.sh</h4>
<ul class=changes><li>install German::Client from package
<a class="date" title="r204" href="http://svn.rot13.org/index.cgi/sysadmin-cookbook/revision?rev=204">2010-05-02 16:24</a></li></ul><a class="path" href="http://svn.rot13.org/index.cgi/sysadmin-cookbook/view/recepies/gearman/0.install.sh">gearman/0.install.sh</a><pre class=content>apt-get install libgearman-client-perl</pre>
<h4>gearman.pl</h4>
<ul class=changes><li>simple perl command-line client depenent only on libgearman-client-perl which is in etch
<a class="date" title="r203" href="http://svn.rot13.org/index.cgi/sysadmin-cookbook/revision?rev=203">2010-05-01 12:49</a></li></ul><a class="path" href="http://svn.rot13.org/index.cgi/sysadmin-cookbook/view/recepies/gearman/gearman.pl">gearman/gearman.pl</a><pre class=content>#!/usr/bin/perl
use warnings;
use strict;
use Data::Dump qw(dump);
use Getopt::Long;
use Gearman::Worker;
my $host = '10.60.0.244:4730';
my $function = 'test';
GetOptions(
'host' => \$host,
'function' => \$function,
) || die $!;
my $worker = Gearman::Worker->new;
$worker->job_servers( $host );
$worker->register_function( $function => sub {
my $job = $_[0];
my $arg = $_[0]->arg;
warn "# job ",dump($job);
});
warn "# worker ",dump($worker);
$worker->work while 1;
=for client
my $client = Gearman::Client->new;
$client->job_servers($host);
# running a single task
my $result_ref = $client->do_task("add", "1+2");
print "1 + 2 = $$result_ref\n";
# waiting on a set of tasks in parallel
my $taskset = $client->new_task_set;
$taskset->add_task( "add" => "1+2", {
on_complete => sub { ... }
});
$taskset->add_task( "divide" => "5/0", {
on_fail => sub { print "divide by zero error!\n"; },
});
$taskset->wait;
=cut</pre>
<h4>grep_logs.sh</h4>
<ul class=changes><li>simple grep_hostname worker
<a class="date" title="r202" href="http://svn.rot13.org/index.cgi/sysadmin-cookbook/revision?rev=202">2010-05-01 12:37</a></li></ul><a class="path" href="http://svn.rot13.org/index.cgi/sysadmin-cookbook/view/recepies/gearman/grep_logs.sh">gearman/grep_logs.sh</a><pre class=content>#!/bin/sh -x
# echo 'error' | gearman -f grep_logs
if [ -z "$1" ] ; then
hostname=`hostname`
exec /srv/gearmand/bin/gearman -h 10.60.0.244 -w -f grep_$hostname $0 $hostname
fi
read pattern
grep $pattern /var/log/*.log</pre>
</p>
</li>
</ul>
</div>
<!-- wiki: {fetchrss: http://sysadmin-=cookbook.rot13.org/rss/gearman.xml full}
--></div><br /></div>
https://saturn.ffzg.hr/rot13/index.cgi?gearman
Dobrica Pavlinušić
2010-05-04T10:02:46Z