allenyang79

import sys
import psycopg2
import psycopg2.extras
conn = psycopg2.connect("host=localhost port=5433 dbname=keycloak user=keycloak password=keycloak")

with conn.cursor(cursor_factory=psycopg2.extras.DictCursor) as cur:
    cur.execute('show pool_nodes')
    result = cur.fetchall()
    result = sorted(result, key=lambda x:x['hostname'])
    #print result

allenyang79

db.monitoringTest.drop()
while(true) {
	for(i = 0; i < 1000 ; i++) {
		db.monitoringTest.insert({'i':i})
	}
	for(i = 0; i < 1000 ; i++) {
		db.monitoringTest.update({'i':i}, {$set:{'text':'text'}})
	}	
	cursor = db.monitoringTest.find()
	while(cursor.hasNext()) {

allenyang79

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

from flask import Flask, session


app = Flask(__name__)
app.config['SECRET_KEY']= 'session123'
app.config['SESSION_COOKIE_PATH'] = '/count/deep'

allenyang79

function TrimEndLines()
    let cursor = getpos(".")
    :%s#\($\n\s*\)\+\%$##
    call setpos('.', cursor)
endfunction

au BufWritePre *.py call TrimEndLines()

allenyang79

import time
import logging
from multiprocessing import Process, Pipe, Queue

logging.basicConfig(level=logging.DEBUG, format='%(asctime)s|%(levelname)-5.5s|%(processName)-10s| %(message)s')
logger = logging.getLogger()


def master():
    logger.info('master start')

allenyang79

import wrapt
import inspect


@wrapt.decorator
def pass_through(wrapped, instance, args, kwargs):
    print "call pass_through", wrapped, instance
    return wrapped(*args, **kwargs)

allenyang79

# -*- coding: utf-8 -*-
import os
import time
import random
import logging
from multiprocessing import Process, Queue

#formatter = logging.Formatter('%(asctime)s %(levelname)s %(message)s')
logging.basicConfig(level=logging.DEBUG, format='%(asctime)s|%(levelname)4s|%(processName)-10s| %(message)s')
logger = logging.getLogger()

allenyang79

docker stack deploy a multi overlay network with mutli service.

allenyang79

動態render cells 透用style, merged.

allenyang79

import functools
import inspect
import time
import random


def memorize(keyfn, scenario='default', timeout=300):
    def wrapper(fn):
        _cached = {}