evilabandon

#!/usr/bin/python

# -- stdlib --
import json
import os
import urllib2

# -- third party --
# -- own --
# -- code --

evilabandon

curl -XPUT localhost:9200/_template/logstash -d @logstashtemplate.json


{
    "template" : "logstash*",
"mappings" : {
"tengine" : {
        "_source" : {
          "compress" : true
        },

evilabandon

{
    "template": "logstash-*",
    "settings" : {
        "number_of_shards" : 1,
        "number_of_replicas" : 0,
        "index" : {
            "query" : { "default_field" : "@message" },
            "store" : { "compress" : { "stored" : true, "tv": true } }
        }
    },

evilabandon

#!/home/yinyong/app/python/bin/python
# -*- coding=utf-8 -*-
  
#module
import multiprocessing
import urllib2
import json
import os
import sys
reload(sys)

evilabandon

#!/usr/bin/env python

import sys, os, time, atexit
from signal import SIGTERM 

class Daemon:
        """
        A generic daemon class.

        Usage: subclass the Daemon class and override the run() method