baybatu

RabbitMQ: Mesajı Geciktirerek Tüketmek

• delay-exchange: Geciktirilecek mesajın bırakıldığı exchange.
• delay-queue: delay-exchange'e bağlı. Herhangi bir tüketicisi olmamalı.
• ana-exchange: Geciktirilmeden tüketilmek istenen mesajların bırakılabileceği exchange.
• ana-queue: ana-exchange'e bağlı kuyruk. Tüketicisi var.

delay-queue şu parametrelerle oluşturulur:

• x-dead-letter-exchange: -- boş
• x-message-ttl: 3000 -- mesajın bekletileceği milisaniye

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

// 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

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

# 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}")

baybatu

SHOW CREATE TABLE tableName;

source: https://prestodb.io/docs/current/sql/show-create-table.html#examples

baybatu

@ControllerAdvice
public class PageResponseAdvice implements ResponseBodyAdvice<Object> {

    @Override
    public boolean supports(MethodParameter returnType, Class<? extends HttpMessageConverter<?>> converterType) {
        return PageResponse.class.isAssignableFrom(returnType.getParameterType());
    }

    @Override
    public Object beforeBodyWrite(Object body,