From 33ffc7d5c84ef714dfc8d428df5c5119603c6cca Mon Sep 17 00:00:00 2001 From: Fernando Andre Date: Sat, 15 Jun 2019 17:13:38 +0100 Subject: [PATCH] Example worker.py shows an example worker Example worker that can be used for tasks. --- docs/example_worker.py | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) create mode 100644 docs/example_worker.py diff --git a/docs/example_worker.py b/docs/example_worker.py new file mode 100644 index 0000000..54cb2cc --- /dev/null +++ b/docs/example_worker.py @@ -0,0 +1,22 @@ +# This is an example for Worker and tasks client. + +# worker.py + +from python3_gearman.worker import GearmanWorker +import os + +gm_worker = GearmanWorker(['192.168.122.212:4730']) + +def task_listener_reverse(gearman_worker, gearman_job): + print(str(os.getpid()) + ":Reversing string: " + gearman_job.data) + import time + time.sleep(5) + return gearman_job.data[::-1] + + +gm_worker.set_client_id("python-worker_"+str(os.getpid())) +gm_worker.register_task("reverse", task_listener_reverse) + +gm_worker.work() + +# worker.py end