nooperpudd

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

# encoding:utf-8

import logging
import  sys
import logging
from optparse import OptionParser
from sleekxmpp import ClientXMPP

nooperpudd

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

from itertools import *

# imap
for i in imap(lambda x:x*2,xrange(5)):
  print i 
# starmap
values=[(1,2),(5,23),(8,9)]

nooperpudd

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


class WithInContext(object):
  """docstring for WithInContext"""
	def __init__(self,context):
		print "WithInContext.__init__(%s)" % context
	def do_something(self):
		print "WithInContext.do_something"

nooperpudd

def dict_common_keys(dict_list):
    """
    check python dict list common keys
    :param dict_list: [{},{}...]
    :return: 
    """
    if len(dict_list) >= 2:
        common_keys = set(dict_list[0].keys())
        for dict_item in dict_list[1:]:

nooperpudd

import asyncio
import sys

async def execute(command, cwd=None, shell=True):
    process = await asyncio.create_subprocess_exec(*command,
                                                   stdout=asyncio.subprocess.PIPE,
                                                   stderr=asyncio.subprocess.PIPE,
                                                   cwd=cwd,
                                                   shell=shell)
    std_out, std_err = await process.communicate()

nooperpudd

def sort_by_domain(sites):
    sitebits = [site.lower().lstrip('http://').split('.') for site in sites]
    for site in sitebits:
        site.reverse()
    print(sitebits)
    return [('.'.join(reversed(site))) for site in sorted(sitebits)]

nooperpudd

from memory_profiler import profile
from itertools import filterfalse

@profile(precision=1)
def test():
    a = []
    for i in range(100000):
        a.append((10.23 + i, {"data": i}))

    b = filterfalse(lambda x: float(x[0]) >= 1000.26, a)

nooperpudd

def check_dict_common_keys(dict_list):
    """
    check the dict common keys in the dict list
    :param dict_list: [{},{}...] 
    :return: set()
    """
    if len(dict_list) >= 2:
        common_keys = set(dict_list[0].keys())
        for dict_item in dict_list[1:]:
            common_keys.intersection_update(set(dict_item.keys()))

nooperpudd

def single_task(lock_arg, lock_prefix="lock-", timeout=CeleryConfig.LOCK_DEFAULT_TIMEOUT):
    """
    :param lock_arg: set the lock key of the task parameter
    :param lock_prefix:
    :param timeout: set the lock key timeout 
    Enforce only one celery task at a time.
    """

    def task_exec(func):
        @functools.wraps(func)

nooperpudd

def single_task(lock_arg, lock_prefix="lock-", timeout=CeleryConfig.LOCK_DEFAULT_TIMEOUT):
    """
    :param lock_arg: set the lock key of the task parameter
    :param lock_prefix:
    :param timeout: set the lock key timeout 
    Enforce only one celery task at a time.
    """

    def task_exec(func):
        @functools.wraps(func)