#!/usr/bin/env python#coding:utf-8frommultiprocessing import Pooldef Func(param1, param2, param3, ...):...if __name__ == '__main__':pool = Pool(5) #定义一个个进程的进程池for ... :pool.app

#!/usr/bin/env python#coding:utf-8from pymongo import MongoClientfrom pymongo import MongoReplicaSetClientif __name__ == '__main__':mongodbHostPort1 = 'mongodb://%s:%s@%s:27017,%s:27017,%s:27017

文本内容：#!/usr/bin/env python# -*- coding=utf-8 -*-import smtplibfrom email.mime.text import MIMETextdef send_mail(to_list,sub,content):mail_host = "***"# 设置服务器mail_user = "***"# 用户名m

searchstr_map.py#!/usr/bin/env python#coding:utf-8import sysimport refor line in sys.stdin:line = line.strip()fields = line.split("\t")cityid = str(fields[0])searchstr = fields[1]

#!/usr/bin/env python#coding:utf-8import loggingif __name__=='__main__':logging.basicConfig(level=logging.DEBUG,format='%(asctime)s %(filename)s[line:%(lineno)d] %(le

HiveServer2为客户端在远程执行hive查询提供了接口，通过Thrift RPC来实现，还提供了多用户并发和认证功能。目前使用python的用户可以通过pyhs2这个模块来连接HiveServer2，实现查询和取回结果的操作。hive_client.py#!/usr/bin/env python#coding:utf-8import pyhs2'''hive client'''cla

#!/usr/bin/env python#coding:utf-8import pyssdbssdb = pyssdb.Client(host=ip, port=port)key = 'app'value['pv']=514ssdb.hset('hash_tbl_name',key,json.dumps(value,ensure_ascii=False))

#!/usr/bin/env python#coding:utf-8''''''import sysimport urlparseimport reimport datetimeimport MySQLdbimport loggingfrom pymongo import MongoClientfrom pyspark import SparkContext, SparkCon

ftp/FtpServer.py#!/usr/bin/env python#coding:utf-8import sysfrom pyftpdlib.authorizers import DummyAuthorizerfrom pyftpdlib.handlers import FTPHandler, ThrottledDTPHandlerfrom pyftpdlib.servers imp