adamchainz

# refactor of https://lukeplant.me.uk/blog/posts/double-checked-locking-with-django-orm/
# untested

def double_checked_lock_iterator(queryset):
    for item_pk in queryset.values_list("pk", flat=True):
        with transaction.atomic():
            try:
                yield queryset.select_for_update(skip_locked=True).get(id=item_pk)
            except queryset.model.DoesNotExist:
                pass

tonybaloney

import _xxsubinterpreters as interpreters
import threading
import textwrap as tw
import pickle

# Create a sub-interpreter
interpid = interpreters.create()

# If you had a function that generated a numpy array
arry = [5,4,3,2,1]

shinaisan

Short Example of Logstash Multiple Pipelines

This gist is just a personal practice record of Logstash Multiple Pipelines.

The following summary assumes that the PATH contains Logstash and Filebeat executables and they run locally on localhost.

Logstash config

pydevops

• 0.1. References
• 0.2. Other cheatsheets
• 0.3. Manage multiple gcloud config configurations
  • 0.3.1. Switch gcloud context with gcloud config
• 0.4. Credentials
• 0.5. info
• 0.6. projects
• 0.7. zones & regions
• 0.8. Organization
• 0.9. billing

robustican

from __future__ import print_function, absolute_import, unicode_literals

import time
try:
    from Queue import Empty
except ImportError:
    from queue import Empty

from multiprocessing import Process, cpu_count, Manager
import logging

thehesiod

from inspect import iscoroutinefunction, isawaitable
import sys
from collections import deque


# NOTE: this follows the contextlib.ExitStack implementation


class _BaseExitStack:
    def __init__(self):

bertrandmartel

MongoDB $lookup aggregation

SO link

db.votes.aggregate([{
    $lookup: {
        from: "users",
        localField: "createdBy",
        foreignField: "_id",

akatrevorjay

import sys
import re


def format_dict_recursively(mapping, raise_unresolvable=True, strip_unresolvable=False, conversions={'True': True, 'False': False}):
    """Format each string value of dictionary using values contained within
    itself, keeping track of dependencies as required.

    Also converts any formatted values according to conversions dict.

goFrendiAsgard

#!/usr/bin/env python
'''
Kanban + Pomodoro + Reminder
If you use linux please install sox first (sudo apt-get install sox)
You can use these formats in order to remind you of the tasks:
    * Y:m:d H:M:S
    * Y:m:d H:M
    * everyday H:M[:S]
    * every [monday|tuesday|wednesday|thursday|friday|saturday] H:M[:S]
    * *:m:d H:M[:S]

julianthome

#!/usr/bin/env python

# export data sheets from xlsx to csv

from openpyxl import load_workbook
import csv
from os import sys

def get_all_sheets(excel_file):
    sheets = []