Implement indexing into Apache Druid #1

Closed
m wants to merge 263 commits from druid into master
2 changed files with 10 additions and 3 deletions
Showing only changes of commit bf802d7fdf - Show all commits

View File

@ -53,7 +53,6 @@ services:
- ./docker/data:/var/lib/manticore - ./docker/data:/var/lib/manticore
- ./docker/manticore.conf:/etc/manticoresearch/manticore.conf - ./docker/manticore.conf:/etc/manticoresearch/manticore.conf
tmp: tmp:
image: busybox image: busybox
command: chmod -R 777 /var/run/redis command: chmod -R 777 /var/run/redis
@ -63,6 +62,11 @@ services:
redis: redis:
image: redis image: redis
command: redis-server /etc/redis.conf command: redis-server /etc/redis.conf
ulimits:
nproc: 65535
nofile:
soft: 65535
hard: 65535
volumes: volumes:
- ${PORTAINER_GIT_DIR}/docker/redis.conf:/etc/redis.conf - ${PORTAINER_GIT_DIR}/docker/redis.conf:/etc/redis.conf
volumes_from: volumes_from:

View File

@ -1,13 +1,16 @@
import asyncio
import ujson
import db import db
import util import util
import ujson
import asyncio
SOURCES = ["irc"] SOURCES = ["irc"]
KEYPREFIX = "queue." KEYPREFIX = "queue."
CHUNK_SIZE = 1000 CHUNK_SIZE = 1000
ITER_DELAY = 0.5 ITER_DELAY = 0.5
class Ingest(object): class Ingest(object):
def __init__(self): def __init__(self):
name = self.__class__.__name__ name = self.__class__.__name__