salah93

from confluent_kafka import Consumer

consumer = Consumer({'group.id': '1', 'bootstrap.servers': 'localhost:9092'})
consumer.subscribe(['abc'])
m = consumer.poll()
print(m.value())

salah93

import pymongo

from argparse import ArgumentParser
from typing import Any, Dict, List, Tuple


def get_create_string(
    collection: str,
    index_name: str,
    key: List[Tuple[str, int]],

salah93

import redis

from dogpile.cache import make_region
from dogpile.cache.util import function_key_generator
from time import sleep
from typing import Any


client = redis.StrictRedis()
region = (

salah93

function kill-ssh-agent
    killall ssh-agent
    set -e SSH_AGENT_PID
    set -e SSH_AUTH_SOCK
    rm $SSH_ENV > /dev/null 2>&1
end

salah93

#!/bin/bash
set -xeuo pipefail

(
flock -s -w 6 200
cat /tmp/x
echo read
sleep 5
) 200>/tmp/pidlock

salah93

#!/bin/bash
set -xeuo pipefail

username=`whoami`
groupname=$1
shareddirectorypath=$2

# 1.  create group
sudo groupadd $groupname || true

salah93

salah93

Kubernetes

Installations

I am operating on a Fedora 31 OS with docker installed, I can run minikube on my machine directly (rather than in a vm) with docker by specifying minikube with --driver=docker.

I think this will be fine for development/exploration.

salah93

# notes from Łukasz Langa's video https://www.youtube.com/watch?v=-CzqsgaXUM8
import asyncio                                                                            
import time

import httpx
                                                                                          
from typing import *                                                                      
                                                                                          
                                                                                          
addr = "https://langa.pl/crawl/"                                                            

salah93

import requests                                                                           
                                                                                          
from argparse import ArgumentParser                                                       
from urllib3.util.retry import Retry                                                      
                                                                                          
                                                                                          
def main(args):                                                                           
    s = get_session()                                                             
    response = s.get(args.url)                                                            
    return response.status_code