michalc

import datetime
import hashlib
import hmac
import urllib.parse


def aws_sig_v4_headers(access_key_id, secret_access_key, pre_auth_headers,
                       service, region, host, method, path, query, payload):
    algorithm = 'AWS4-HMAC-SHA256'

michalc

def normalise_environment(key_values):
    ''' Converts denormalised dict of (string -> string) pairs, where the first string
        is treated as a path into a nested list/dictionary structure

        {
            "FOO__1__BAR": "setting-1",
            "FOO__1__BAZ": "setting-2",
            "FOO__2__FOO": "setting-3",
            "FOO__2__BAR": "setting-4",
            "FIZZ": "setting-5",

michalc

import csv
import logging

import gevent
from psycopg2 import (
    connect,
    sql,
)

from django.conf import (

michalc

from ctypes import (
    byref,
    c_char_p, c_uint32, c_uint16, c_ubyte,
    CDLL,
    POINTER,
    pointer,
    Structure, Union,
    sizeof,
)
import platform

michalc

import asyncio
import contextlib

from fifolock import FifoLock

class Read(asyncio.Future):
    @staticmethod
    def is_compatible(holds):
        return not holds[Write]

michalc

import asyncio
import contextlib
import weakref

from fifolock import FifoLock

class Read(asyncio.Future):
    @staticmethod
    def is_compatible(holds):
        return not holds[Write]

michalc

import asyncio
import contextlib
import weakref

from fifolock import FifoLock

class ReadAncestor(asyncio.Future):
    @staticmethod
    def is_compatible(holds):
        return not holds[Write]

michalc

import asyncio
import collections
import contextlib

class Read(asyncio.Future):
    @staticmethod
    def is_compatible(holds):
        return not holds[Write]

class Write(asyncio.Future):

michalc

import asyncio
import contextlib

class PathLock():

    def __init__(self):
        self.lock = asyncio.Lock()

    @contextlib.asynccontextmanager
    async def __call__(self, read, write):

michalc

import asyncio
import os
import aiohttp

from aws_sig_v4_headers import aws_sig_v4_headers


async def main():
    method = 'PUT'
    host = 's3-eu-west-1.amazonaws.com'