我用Python编写了一个使用多处理的小脚本。我曾想过在googleappengine上运行它作为cron作业,但不幸的是googleappengine不支持多处理。有人能帮我把这个转换成googleappengine兼容的代码吗?在
from multiprocessing import Pool
import MySQLdb
import urllib;
import urllib2;
def f(email_url):
url = "http://my-domain.com/cron.php"
values = { "email" : email_url[0], "url" : email_url[1] }
data = urllib.urlencode(values)
req = urllib2.Request(url, data)
urllib2.urlopen(req)
if __name__ == '__main__':
p = Pool()
emails_urls = list()
conn = MySQLdb.connect(host = "XXX.XXX.XXX.XXX", user = "USERNAME",
passwd = "PASSWORD", db = "MY-DATABASE")
cursor = conn.cursor()
cursor.execute ("SELECT email, url FROM data")
rows = cursor.fetchall()
for row in rows:
emails_urls.append((row[0], row[1]))
cursor.close()
conn.close()
p.map(f, emails_urls)
看看任务队列。在
ca可以在任务队列(=>;线程)中插入一定数量的工作,并设置队列中同时执行的作业数。在
看这里:http://code.google.com/intl/de-DE/appengine/docs/python/taskqueue/
相关问题 更多 >
编程相关推荐