ネリモノ系

Twitter: https://twitter.com/msbtjp

worker

from gearman import GearmanWorker

def dump(job):
    #ここらへんでデータ加工するなどする
    ret = job['name']
    return ret

if __name__ == '__main__':
    worker = GearmanWorker(["127.0.0.1:4730"])
    worker.register_function("dump", lambda job:dump(eval(job.arg)))
    worker.work()

上のソースは適当に殴り書きしたやつだから動くかどうかわからないけど、下の方にあるlambdaとevalを組み合わせてる部分だけ見て貰えればわかると思うよ!
あとはDBにクエリを投げて結果を加工して返すようなfunctionとか作ればapiサーバとして動作させることができますね。


python-gearman: http://github.com/samuel/python-gearman/tree/master