baybatu

import asyncio
import functools

from schedule import Scheduler


class AsyncScheduler(object):
    """
        schedule (https://github.com/dbader/schedule) and asyncio integration example.
        Jobs are executed in asyncio event loop without blocking another tasks.

baybatu

# create exchange
curl -i -u guest:guest -H "content-type:application/json" \
    -XPUT -d'{"type":"fanout","durable":true}' \
    http://localhost:15672/api/exchanges/%2f/my.exchange.name
    
# create queue
curl -i -u guest:guest -H "content-type:application/json" \
    -XPUT -d'{"durable":true,"arguments":{"x-dead-letter-exchange":"", "x-dead-letter-routing-key": "my.queue.dead-letter"}}' \
    http://localhost:15672/api/queues/%2f/my.queue

baybatu

// usage: groovy nifi-test-el.groovy '${now():toNumber():minus(3999900000):format("yyyy-MM-dd HH:mm:ss", "GMT")}'
// source: https://community.cloudera.com/t5/Community-Articles/Testing-NiFi-Expression-Language-with-Groovy/ta-p/247208
@Grab(group='org.apache.nifi', module='nifi-expression-language', version='1.4.0')
import org.apache.nifi.attribute.expression.language.*

def cli = new CliBuilder(usage:'groovy testEL.groovy [options] [expressions]',
                          header:'Options:')
cli.help('print this message')
cli.D(args:2, valueSeparator:'=', argName:'attribute=value',
       'set value for given attribute')

baybatu

~/.gitconfig:

[includeIf "gitdir:~/workspace/project1/**"]
    path = .gitconfig.project1
[includeIf "gitdir:~/workspace/project2/**"]
    path = .gitconfig.project2

~/.gitconfig.project1:

baybatu

def limit(num, minimum=1, maximum=255):
  """Limits input 'num' between minimum and maximum values.
  Default minimum value is 1 and maximum value is 255."""
  return max(min(num, maximum), minimum)

baybatu

Ilginc bir projeye benziyor. Prototipleme yaparken ya da hizlica bir seyleri denemek istedigimizde kullanilabilir.

https://github.com/pywebio/PyWebIO

baybatu

\copy (select column1, column2 from mytable) To '/tmp/dump.csv' With CSV DELIMITER ',' HEADER

baybatu

/*
* 
* Methods manipulate milliseconds field (fastTime) in java.util.Date object.
*
* UTC               : 12/10/2017 11:15:00
* Local date time   : 12/10/2017 14:15:00 +03:00
*   
* @return new java.util.Date
*       UTC             : 12/10/2017 14:15:00
*       Local date time : 12/10/2017 17:15:00 +03:00

baybatu

Removing keys that contain displayed:

redis-cli --scan --pattern *displayed* | xargs redis-cli del

Source: https://rdbtools.com/blog/redis-delete-keys-matching-pattern-using-scan

baybatu

# usage
# python delete-index-by-pattern-in-es.py http://ES_HOST:9200 my-es-index-*
# indexes matched with pattern you entered will be deleted
from elasticsearch import Elasticsearch
import sys

es_host = sys.argv[1]
index_pattern = sys.argv[2]

print(f"es_host:{es_host} ; index_pattern:{index_pattern}")