tawateer

#-*- coding: utf-8 -*- 
"""  封装成装饰器.

"""

import sys
import time
import threading

tawateer

import heapq
import random

class BtmkHeap(object):
    def __init__(self, k):
        self.k = k
        self.data = []

    def Push(self, elem):
        # Reverse elem to convert to max-heap

tawateer

#!/usr/bin/env python

"""
How to use it:
1. Just `kill -2 PROCESS_ID` or `kill -15 PROCESS_ID` , The Tornado Web Server Will shutdown after process all the request.
2. When you run it behind Nginx, it can graceful reboot your production server.

3. Nice Print in http://weibo.com/1682780325/zgkb7g8k7

"""

tawateer

server {
        listen 80;
        server_name {{ server_name }};
        access_log {{ access_log }} main;
        error_log {{  error_log }};

        location / {
            access_by_lua '
                local reqType = ngx.var.request_method
                if reqType == "T"

tawateer

#-*- coding: utf-8 -*-

import redis


REDIS_HOST = "localhost"
REDIS_PORT = 6379
REDIS_DB1 = 0
REDIS_DB2 = 1
REDIS_DB3 = 2

tawateer

from concurrent.futures import ThreadPoolExecutor
from functools import partial, wraps
import time

import tornado.ioloop
import tornado.web


EXECUTOR = ThreadPoolExecutor(max_workers=4)

tawateer

#!/bin/env python
# -*- coding: utf-8 -*-

import os
import time
import logging
from logging.handlers import TimedRotatingFileHandler


LOG_DIR = "/tmp/"

tawateer

#-*- coding: utf-8 -*-

"""
方法1, 实现 __new__ 方法
并在将一个类的实例绑定到类变量 _instance上,  
如果 cls._instance 为 None 说明该类还没有实例化过,实例化该类,并返回  
如果 cls._instance 不为 None , 直接返回 cls._instance 

"""

tawateer

#!/bin/bash


# set the path to nginx log files
log_files_path="/home/work/nginx/logs/"
#log_files_dir=${log_files_path}/$(date -d "yesterday" +"%Y")/$(date -d "yesterday" +"%m")
log_files_dir="$log_files_path"

# set nginx log files you want to cut
log_files_type=(access error)

tawateer

#!/bin/env python
# -*- coding: utf-8 -*-

import subprocess


text="""
test0 test10
test1 test11
"""