klizhentas

"""Aggregates events in batches and flushes them after max batch size
have been achieved or certain amount of seconds has passed
"""
import logging
from threading import Lock
from datetime import datetime

log = logging.getLogger(__name__)

FLUSH_SECONDS = 3

klizhentas

  :cluster_name => "Mailgun Tanks",
  :initial_token => "",
  :version => '1.2.5',
  :user => "cassandra",
  :jvm  => {
    :xms => 32,
    :xmx => 512
  },
  :limits => {
    :memlock => 'unlimited',

klizhentas

CREATE TABLE hits (
      hit text PRIMARY KEY,
      counter counter
    ) WITH COMPACT STORAGE;

UPDATE hits USING TTL 3600 SET counter = counter + 1 WHERE hit='api-call-some-hour';

klizhentas

from operator import attrgetter, itemgetter
from itertools import groupby, chain
from random import shuffle

from twisted.names.client import Resolver
from twisted.internet import defer
from twisted.python import log

def init(config):
    R.resolver = Resolver(resolv='/etc/resolv.conf')

klizhentas

# http://notmysock.org/blog/hacks/a-twisted-dns-story.html
# http://blog.inneoin.org/2009/11/i-used-twisted-to-create-dns-server.html
# twistd -y dns.py
import socket
 
from twisted.internet import reactor
from twisted.names import dns
from twisted.names import client, server
from twisted.web.server import Site
import klein

klizhentas

from time import time
from logging.config import fileConfig
from twisted.internet import epollreactor
epollreactor.install()

from flask import Flask, request

app = Flask(__name__)

fileConfig("logging.ini")

klizhentas

from time import time
from logging.config import fileConfig
from twisted.internet import epollreactor
epollreactor.install()

from flask import Flask, request

app = Flask(__name__)

fileConfig("logging.ini")