This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from argparse import ArgumentParser | |
import sys | |
import json | |
import datetime | |
import os | |
import logging | |
import hashlib | |
import boto3 | |
from botocore.config import Config |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python | |
import argparse | |
import sys | |
import timeit | |
from swift.common.utils import Namespace | |
from swift.container.backend import ContainerBroker | |
parser = argparse.ArgumentParser() | |
parser.add_argument('path', help='path to the .db') |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import logging | |
import eventlet.patcher | |
eventlet.patcher.monkey_patch(thread=True) | |
import threading | |
def take_and_release(): | |
try: | |
logging._lock.acquire() | |
finally: |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
vagrant@saio:~$ curl http://127.0.0.4:6041/sdb4/47/AUTH_test/container-6fb8e61f-f131-4037-9219-83c400ba81e7 -v | |
* Trying 127.0.0.4:6041... | |
* TCP_NODELAY set | |
* Connected to 127.0.0.4 (127.0.0.4) port 6041 (#0) | |
> GET /sdb4/47/AUTH_test/container-6fb8e61f-f131-4037-9219-83c400ba81e7 HTTP/1.1 | |
> Host: 127.0.0.4:6041 | |
> User-Agent: curl/7.68.0 | |
> Accept: */* | |
> | |
* Mark bundle as not supporting multiuse |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python | |
import sys | |
import os | |
import errno | |
from argparse import ArgumentParser | |
from collections import defaultdict | |
import pickle | |
import logging | |
try: | |
import thread |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
grpc/examples/python/helloworld$ python async_greeter_server.py | |
DEBUG:asyncio:Using selector: EpollSelector | |
DEBUG:grpc._cython.cygrpc:Using AsyncIOEngine.POLLER as I/O engine | |
INFO:root:Starting server on [::]:50051 | |
^CDEBUG:grpc._cython.cygrpc:__dealloc__ called on running server <grpc._cython.cygrpc.AioServer object at 0x7f49685adc10> with status 4 | |
Traceback (most recent call last): | |
File "async_greeter_server.py", line 50, in <module> | |
asyncio.run(serve()) | |
File "/usr/lib/python3.8/asyncio/runners.py", line 43, in run | |
return loop.run_until_complete(main) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python | |
from argparse import ArgumentParser | |
import sys | |
import json | |
import boto3 | |
parser = ArgumentParser() | |
parser.add_argument('bucket', help='Bucket to make') |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from swift.common.utils import Watchdog, WatchdogTimeout, GreenAsyncPile | |
from eventlet.greenthread import spawn | |
from eventlet import sleep, Timeout | |
import random | |
watchdog = Watchdog() | |
watchdog.spawn() | |
def range_iter(start=0): |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python | |
from argparse import ArgumentParser | |
import json | |
from swift.common.memcached import MemcacheRing | |
from swift.proxy.controllers.base import get_cache_key | |
import sys | |
parser = ArgumentParser() | |
parser.add_argument('container', help='Name of container to check') |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from argparse import ArgumentParser | |
import sys | |
import time | |
import boto3 | |
parser = ArgumentParser() | |
parser.add_argument('bucket', help='bucket to make the upload') | |
parser.add_argument('key', nargs='?', help='key name for large object') |
NewerOlder