FROM: http://www.ttlsa.com/distributed-processing-systems/gearman-python-example/

有关gearman的介绍,可以参见本博客之前的文章。

gearman的Python客户端使用蛮简单的。具体方法参见:http://pythonhosted.org//gearman/library.html

worker:

from  gearman import GearmanWorker
from var_dump import var_dump
import json
 
def worker_ttlsa.com(gearman_worker,job):
    var_dump(job.data)
    param = json.loads(job.data)
    sleep = param['sleep']
    return str(sleep)
 
def main():
    gw = GearmanWorker(['127.0.0.1:4730'])
    gw.register_task("worker_ttlsa.com", worker_ttlsa.com)
    gw.work()
 
if __name__ == "__main__":
    main()

client:

from gearman import GearmanClient
from var_dump import var_dump
import json
 
def main():
    gc = GearmanClient(['127.0.0.1:4730'])
    param = {'msg':'www.ttlsa.com', 'sleep':5}
     
    request = gc.submit_job('worker_ttlsa.com',json.dumps(param))
    var_dump(request.result)
 
if __name__ == "__main__":
    main()

注意:worker一定要有retrun,且返回的内容必须是字符串。否则报下面的错误。

TypeError: Expecting byte string, got <type ‘NoneType’>

查看状态:

# telnet 127.0.0.1 4730
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
workers
36 127.0.0.1 - :
35 127.0.0.1 - : worker_ttlsa.com
.
status
worker_ttlsa.com    0       0       1
.

status输出分4个部分:已注册的任务,正在运行的任务,队列中的任务,可用的worker。

gearman python 实例相关推荐

  1. python接收输入的一行字符只统计数字的个数,Python(统计字符),python实例,输入一行字符,分别统计出其中英文字母、空格、数字和其它字符的个数...

    Python(统计字符),python实例,输入一行字符,分别统计出其中英文字母.空格.数字和其它字符的个数 题目:输入一行字符,分别统计出其中英文字母.空格.数字和其它字符的个数. 程序分析:利用 ...

  2. Python实例浅谈之三Python与C/C++相互调用

    参考:http://blog.csdn.net/taiyang1987912/article/details/44779719 Python实例浅谈之三Python与C/C++相互调用 二.Pytho ...

  3. python写文件读文件-Python 实例:读写文件

    原标题:Python 实例:读写文件 读写文件是最常见的IO操作.内置了读写文件的函数,用法和的读写文件非常类似.在磁盘上读写文件的功能都是由提供的,现代不允许普通的程序直接操作磁盘,所以,读写文件就 ...

  4. 使用docker安装部署Spark集群来训练CNN(含Python实例)

    使用docker安装部署Spark集群来训练CNN(含Python实例) 本博客仅为作者记录笔记之用,不免有很多细节不对之处. 还望各位看官能够见谅,欢迎批评指正. 博客虽水,然亦博主之苦劳也. 如需 ...

  5. python现有两个磁盘文件a和b_有两个磁盘文件A和B,各存放一行字母,要求把这两个文件中的信息合并(按字母顺序排列), 输出到一个新文件C中Python实例...

    有两个磁盘文件A和B,各存放一行字母,要求把这两个文件中的信息合并(按字母顺序排列), 输出到一个新文件C中Python实例 题目:有两个磁盘文件A和B,各存放一行字母,要求把这两个文件中的信息合并( ...

  6. Python实例讲解 -- 磁盘文件的操作

    在文件夹里有六十多个RM格式的视频文件,我现在需要把它们的文件名都提取出来,并去掉文件的扩展名,以便放到需要的网页里. 应该有什么软件可以完成这个简单的要求,可是一时间到哪里去找这 样一个符合要求的软 ...

  7. python抽签代码_Python(抽签问题),python实例,

    Python(抽签问题),python实例, 题目:两个乒乓球队进行比赛,各出三人.甲队为a,b,c三人,乙队为x,y,z三人.已抽签决定比赛名单.有人向队员打听比赛的名单.a说他不和x比,c说他不和 ...

  8. arcgis python 教程-按区域消除--arcgis python实例教程

    按区域消除--arcgis python实例教程 目的:对应细碎多边形,合并到周围的大多边形中,同时要求在同一个区域.例如对于处理多个县组成的图斑,某一个县的细碎多边形不能合并到别的县 使用方法: 工 ...

  9. shell sort 最后一列排序_十个必知的排序算法|Python实例系列[1]

    实例内容: 十个必知的排序算法具体代码,并简略的得知每种算法对于不同长度数列的排序时间 十大排序: 1.冒泡排序2.选择排序3.插入排序4.希尔排序5.归并排序6.快速排序7.堆排序8.计数排序9.桶 ...

最新文章

  1. Data Mining and Machine Learning in Cybersecurity PDF
  2. JLupin Next Server乍一看
  3. 语言中的petchar运用_还在担心你家孩子发音、语言问题?12个表现、3个预防是重点...
  4. python conf配置文件
  5. Linux NFS存储服务部署
  6. java 关闭进程_java在进程启动和关闭.exe程序
  7. 数字图像处理—美图秀秀:磨皮算法
  8. android自动循环播放视频,Android编程实现VideoView循环播放功能的方法
  9. 双稳态电路的两个稳定状态是什么_555时基电路内部结构及其工作原理
  10. 网易云信七鱼市场总监姜菡钰:实战解读增长黑客在B端业务的运用
  11. dm服务器未能启动,救命啊!IDES无法启动了!!!!
  12. MacVim中文乱码解决
  13. oracle bpm 二次开发,Oracle BPM Suite产品详细说明
  14. C++学习目标、体系、计划
  15. 分类器评估指标——混淆矩阵 ROC AUC KS AR PSI Lift Gain
  16. 配置域名 二级,三级的泛解析
  17. Linux ❉ sudo 命令
  18. Unable to locate tools.jar. Expected to find it in D:/jre6/lib/tools.jar问题解决
  19. MVC和MVP到底有什么区别呢?
  20. 用JAVA实现输入年月日,输出这是一年的第几天,是星期几

热门文章

  1. PERL 语言中的q,qw,qr,qx,qq......符号用法总结
  2. linux进程--进程与线程(十二)
  3. leetcode算法题--反转链表★
  4. matlab 读取csv_利用Pytorch进行数据加载1--CSV文件的读取和显示
  5. finally 关键字
  6. JavaSE(十)之反射
  7. SpringMVC REST 风格静态资源访问配置
  8. 笑谈.Net的开发境界
  9. php 时间 插件,PHP中Carbon日期时间处理利器详解
  10. recyclerview item动画_RecyclerView 的 Item 酷炫动画,效果加案例讲解!