#!/usr/bin/python #encoding=utf-8 import beanstalkc import yaml import json import MySQLdb #load config handle = open('config.yaml') conf = yaml.load(handle) #get data from beanstalkd def get_beanstalk_data(conf): beanstalk = beanstalkc.Connection(host=conf['beans']['host'],port=conf['beans']['port']) beanstalk.use('test') beanstalk.watch('test') job = beanstalk.reserve() data = json.loads(job.body) job.delete() return data #insert data to mysql def insert_to_mysql(conf,data): try: conn = MySQLdb.connect(host=conf['mysql']['host'], user=conf['mysql']['user'],passwd=conf['mysql']['pass'], port=conf['mysql']['port'], db=conf['mysql']['db']) cursor = conn.cursor() sql = "insert into stat_plugin_log (id, md, cd, st) values(%s, %s, %s, %s)" param = (data['id'], data['md'], data['cd'], data['st']) cursor.execute(sql, param) cursor.close() conn.close() except MySQLdb.Error,e: print "Mysql Error %d: %s" % (e.args[0], e.args[1]) #go while True: data = get_beanstalk_data(conf) insert_to_mysql(conf,data)
相关推荐
主要介绍了Python使用 Beanstalkd 做异步任务处理的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
Python使用Beanstalkd做异步任务处理的方法共5页.pdf.zip
Python使用Beanstalkd做异步任务处理的方法共5页.pdf.zip
Beanstalkd,一个高性能、轻量级的分布式内存队列系统,最初设计的目的是想通过后台异步执行耗时的任务来降低高容量Web应用系统的页面访问延迟,支持过有9.5 million用户的Facebook Causes应用。后来开源,现在有...
流行的队列驱动
beanstalkd的php语言的sdk,beanstalkd是一种基于memache协议之上的高效队列
Beanstalkd分布式内存队列系统 的 spring boot starter 封装 部署 beanstalkd 服务 docker run -d -p 11300:11300 schickling/beanstalkd ② 引入依赖 <groupId>com.pig4cloud.beanstalk</groupId> <artifactId>...
Beanstalkd中文使用手册 Beanstalk,一个高性能、轻量级的分布式内存队列系统,最初设计的目的是想通过后台异步执行耗时的任务来降低高容量Web应用系统的页面访问延迟,支持过有9.5 million用户的Facebook Causes...
beanstalkd-1.4.6安装包
beanstalkd test client. press test producer and consumer
beanstalkd分布式队列的java客户端,支持连接池,性能为原生的10-20倍。
running on linux x86 64bit
Beanstalkd是一个高性能、轻量级的分布式内存队列系统,它的设计初衷是通过后台异步执行耗时的任务来降低高容量Web应用系统的页面访问延迟。具有如下功能特点。 高性能与轻量级:Beanstalkd是一个高效的内存队列系统...
Laravel开发-laravel-async-beanstalkd 为Laravel框架提供异步beanstack队列驱动程序。
beanstalkd任务队列服务,benanstalkd-console 可视化部署Dockerfile及其镜像,部署命令,Linux 需要docker
go-beanstalk 是beanstalkd 的GO语言的一个客户端。beanstalkd是一个快速的、有各种用途的延迟队列 和定时任务的不同点: 定时任务以一定的周期或者在某个特定的时间运行。
Beanstalkd Docker存储库 使用方法: docker pull jonbaldie/beanstalkd 或者,您可以git clone仓库, make从项目根目录运行make 。 (c)2017乔纳森·巴尔迪
Beanstalkd CLI Usage: beanstalkd-cli [options] put beanstalkd-cli [options] pop beanstalkd-cli [options] monitor beanstalkd-cli [options] stats [] beanstalkd-cli [(--help | --version)] Commands...