Skip to content

Instantly share code, notes, and snippets.

View confiq's full-sized avatar
🐶
first and last status?

Igor Konforti confiq

🐶
first and last status?
View GitHub Profile
@confiq
confiq / send2mq.py
Created January 25, 2016 12:57
send message to 0mq
import zmq
import datetime
def _init():
myzmq = zmq.Context.instance()
publisher = myzmq.socket(zmq.PUB)
publisher.connect("tcp://10.0.100.132:2120")
message = {
"@source": __file__,
"@tags": ["dump_tag", "can_send_email_is_false"],
"@timestamp": datetime.datetime.now().isoformat(),

Keybase proof

I hereby claim:

  • I am confiq on github.
  • I am confiq (https://keybase.io/confiq) on keybase.
  • I have a public key ASBNTsG60KUwDrlpHpz7M3XbN0JSAj7LOuYh14-GmxEUWQo

To claim this, I am signing this object:

The Shins - New Slang
Cold War Kids - Hang Me Up to Dry
London Grammar - Hey Now
Jamie T - Limits Lie
X Ambassadors - Renegades
Tenacious D - Tribute
Titiyo - Come Along
Hozier - Take Me To Church
Berry Sakharof - Tzamah Lecha Nafshi
4 Non Blondes - What's Up?
@confiq
confiq / dmes.log
Created July 26, 2017 08:59
OOM killer
[617568.768581] bash invoked oom-killer: gfp_mask=0x26000c0, order=2, oom_score_adj=0
[617568.768585] bash cpuset=/ mems_allowed=0
[617568.768590] CPU: 0 PID: 4686 Comm: bash Not tainted 4.4.0-83-generic #106-Ubuntu
[617568.768591] Hardware name: Xen HVM domU, BIOS 4.2.amazon 02/16/2017
[617568.768592] 0000000000000286 00000000c18427a2 ffff8800a41f7b10 ffffffff813f9513
[617568.768595] ffff8800a41f7cc8 ffff8800ba798000 ffff8800a41f7b80 ffffffff8120b53e
[617568.768597] ffffffff81cd6fd7 0000000000000000 ffffffff81e677e0 0000000000000206
[617568.768600] Call Trace:
[617568.768605] [<ffffffff813f9513>] dump_stack+0x63/0x90
[617568.768609] [<ffffffff8120b53e>] dump_header+0x5a/0x1c5
@confiq
confiq / kuard.yaml
Last active June 25, 2020 21:26
simple k8s service
apiVersion: apps/v1
kind: Deployment
metadata:
name: kuard
spec:
selector:
matchLabels:
app: kuard
replicas: 1
template:
@confiq
confiq / asyncio.py
Created May 3, 2021 14:49
simple asyncio.Query usage from synchronous loop
import signal
import time
import asyncio, random
# import uvloop
# asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
async def consumer(queue):
while True:
revision = await queue.get()
if revision is False:
apiVersion: v1
kind: Service
metadata:
name: nls-kafka
labels:
app: kafka-app
namespace: default
spec:
type: NodePort
ports: