简单博客

#! /usr/bin/env python
#coding=cp936

from twisted.internet import reactor
from twisted.python import log
from twisted.enterprise import adbapi
from twisted.python.threadpool import  ThreadSafeList


class Ora_pool(object):
    '''
    do_obj  :
        1 Template obj     sql_t  sql语句的模板
        2 sql_t的参数列表para_list 是dict的list
    '''

    def __init__(self, user=None, passwd=None, tns=None, do_obj=None, cp=4):
        self.do_obj = do_obj
        self.dbpool = adbapi.ConnectionPool("cx_Oracle", user, passwd,\
            tns, cp_min=cp, cp_max=cp)
        self.result_list =ThreadSafeList()
        self.err_list = ThreadSafeList()

    def errback(self, e):
        self.err_list.append(e)
        if (len(self.result_list)+len(self.err_list))==\
            len(self.do_obj.para_list):
            self.dbpool.close()
            reactor.stop()

    def run(self):
        if len(self.do_obj.para_list)==0:
            return
        try:
            for para_dict in self.do_obj.para_list:
                d = self.dbpool.runInteraction(self.do_sql, **para_dict)
                d.addCallback(self.do_result)
                d.addErrback(self.errback)
        except:
            log.msg("***gen paras failed!")
            raise
        reactor.run()

    def do_sql(self, trans, **kwags):
        try:
            trans.execute(self.do_obj.sql_t.substitute(**kwags))
        except Exception, e:
            print Exception, e
            log.msg("***ERROR***:%s" %(kwags))
            raise
        return kwags

    def do_result(self, rs):
        log.msg("***DONE***:%s" %(rs))
        self.result_list.append(rs)
        if (len(self.result_list)+len(self.err_list))==\
            len(self.do_obj.para_list):
            self.dbpool.close()
            reactor.stop()

#! /usr/bin/env python
#coding=cp936
import sys
from string import Template
from twisted.python import log
from tw_ora_pool import Ora_pool


class my_sql(object):
    pass

if __name__ == '__main__':
    logfile = sys.stdout
    log.startLogging(logfile)

    test = my_sql()
    test.sql_t = Template('''select count(*) from  dual a
    where ${id}=${id}''')

    test.para_list = [dict(id=i) for i in range(0, 10)]
    dp = Ora_pool(user='xxx', passwd='yyyy', tns='ttt',\
        do_obj=test, cp=4)
    dp.run()

#! /usr/bin/env python
#coding=utf-8

from PIL import Image, ImageDraw, ImageFont
#from math import atan, degrees
import sys
import os,re

def get_jpg_time(filename):
    time_pos = 0x12a
    time_size = 19
    f = open(filename)
    f.seek(time_pos)
    day = f.read(time_size)
    f.close()
    return day


#FONT = "/usr/X11R6/lib/X11/fonts/TTF/Vera.ttf"

FONT = r"C:\WINDOWS\Fonts\STXINGKA.TTF"

#FONT = r"C:\WINDOWS\Fonts\Vrinda.ttf"

def im_mark(filename, outfilename,cor_fill='rgb(0,255,0)',im_size=80):
   #text = re.compile(':').sub('-',get_jpg_time(filename)[:11])
   text = get_jpg_time(filename)
   text = re.compile(':').sub('-',text[:11])+ '  '+text[11:16]
   print text
   img = Image.open(filename).convert("RGB")
   watermark = Image.new("RGBA", (img.size[0], img.size[1]))
   draw = ImageDraw.ImageDraw(watermark, "RGBA")
   size = im_size
   #size =184
   font = ImageFont.truetype(FONT,size)
   nexttextwidth, nexttextheight = font.getsize(text)
   textwidth, textheight = nexttextwidth, nexttextheight

   
   draw.setfont(font)
   draw.text(((watermark.size[0]-textwidth-100),
              (watermark.size[1]-textheight-100)), text,fill=cor_fill)

   img.paste(watermark, None, watermark)
   img.save(outfilename)

if __name__ == "__main__":
    try:
        ori_dir = sys.argv[1]
        dest_dir = sys.argv[2]
    except IndexError:
        print "usage: jpg_mark.py photo_dir new_dir "
        sys.exit(0)
    
    if not os.path.isdir(dest_dir) :    
        os.mkdir(dest_dir)
   
    name_reg = re.compile('jpg$',re.I)

    for im in os.listdir(ori_dir):
        if name_reg.search(im):
            im_mark(os.path.join(ori_dir,im),os.path.join(dest_dir,im))

@app.after_request
def shutdown_session(response): 
    self.session.remove() #把remove改成close就好了
    return response

mysql> show processlist;
+------+------+------------------------------------+------+---------+------+-------+------------------+
| Id   | User | Host                               | db   | Command | Time | State | Info             |
+------+------+------------------------------------+------+---------+------+-------+------------------+
| 1513 | app  | ip-10-118-51-80.ec2.internal:45992 | blog | Sleep   |   68 |       | NULL             |
| 1514 | app  | ip-10-118-51-80.ec2.internal:45995 | blog | Sleep   |   68 |       | NULL             |
| 1515 | app  | ip-10-118-51-80.ec2.internal:46005 | blog | Sleep   |   67 |       | NULL             |
| 1516 | app  | ip-10-118-51-80.ec2.internal:46010 | blog | Sleep   |   66 |       | NULL             |
| 1517 | app  | ip-10-118-51-80.ec2.internal:46020 | blog | Sleep   |   64 |       | NULL             |
| 1518 | app  | ip-10-118-51-80.ec2.internal:46022 | blog | Sleep   |   64 |       | NULL             |
| 1519 | app  | ip-10-118-51-80.ec2.internal:46031 | blog | Sleep   |   62 |       | NULL             |
| 1520 | app  | ip-10-118-51-80.ec2.internal:46036 | blog | Sleep   |   61 |       | NULL             |
| 1521 | app  | ip-10-118-51-80.ec2.internal:46039 | blog | Sleep   |   60 |       | NULL             |
| 1522 | app  | ip-10-118-51-80.ec2.internal:46041 | blog | Sleep   |   59 |       | NULL             |
| 1523 | app  | ip-10-118-51-80.ec2.internal:46107 | blog | Sleep   |   45 |       | NULL             |
| 1524 | app  | ip-10-118-51-80.ec2.internal:46123 | blog | Sleep   |   43 |       | NULL             |
| 1525 | app  | ip-10-118-51-80.ec2.internal:46148 | blog | Sleep   |   36 |       | NULL             |
| 1526 | root | localhost                          | NULL | Query   |    0 | NULL  | show processlist |
+------+------+------------------------------------+------+---------+------+-------+------------------+

#!/usr/bin/env python
import sys
sys.path.append('/home/dotcloud/code')
from pypress import create_app
def application(environ, start_response):
    app = create_app('config.cfg')
    return app(environ, start_response)