分散タスクシステム GEARMAN FOR PYTHON に関する事前検討

Gearman について詳しくは、Gearman 公式 Web サイトをご覧ください: gearman.org/

++++++++++++++++++++++++++++++++ ++++ ++++++++++

Gearman をインストールします:

++++++++++++++++++++++++++++++ ++ ++++++++++

基本的な依存関係ライブラリ:

yum install boost-devel libevent-devel sqlite-devel libuuid-devel
wget https://launchpad.net/gearmand/trunk/0.33/+download/gearmand-0.33.tar.gz 
tar xzvf gearmand-0.33.tar.gz 
cd gearmand-0.33 
./configure
make
make install

++++++++++++++++++++++++++++++ + ++++++++++++

Gearman Python クライアントをインストールします

++++++++++++++++++++++++++++++ ++++++++++++++++

wget http://pypi.python.org/packages/source/g/gearman/gearman-2.0.2.tar.gz#md5=3847f15b763dc680bc672a610b77c7a7 
    tar xvzf  gearman-2.0.2.tar.gz 
    python setup.py install

自動インストールを直接取得します: easy_install gearman

サービスを開始します: gearmand -d

ワーカーを開始します: gearman -w -f wc - - wc -l &

-w はワーカーを開始することを意味します。 -f wc は wc という名前のタスクを開始することを意味します。 -- wc -l は、このタスクが wc -l を実行して行数をカウントすることを意味します。

クライアントの起動: gearman -f wc < /etc/passwd

++++++++++++++++++++++++++++++++ + ++++++++++

Python作業コード:

++++++++++++++++++++++++++++++ ++++++++++++

import os 
import gearman 
import math       
class MyGearmanWorker(gearman.GearmanWorker):   
    def on_job_execute(self, current_job):   
        print "Job started" 
        return super(MyGearmanWorker, self).on_job_execute(current_job)   
     
def task_callback(gearman_worker, gearman_job):   
    print gearman_job.data  
    return gearman_job.data 
     
my_worker = MyGearmanWorker(['192.168.0.75:4730'])   
my_worker.register_task("echo", task_callback)   
my_worker.work()

++++++++++++++++++++++++++++++++++ ++++++++++

Pythonクライアントコード:

++++++++++++++++++++++++++++++++ ++++++++++

りー