mirror of
https://github.com/KevinMidboe/transatlanticTorrentExpress.git
synced 2025-10-29 18:00:19 +00:00
Posts to unique index every day with suffix of todays date
This commit is contained in:
@@ -4,6 +4,7 @@ import logging
|
|||||||
import os
|
import os
|
||||||
import json
|
import json
|
||||||
import uuid
|
import uuid
|
||||||
|
import datetime
|
||||||
import urllib.request
|
import urllib.request
|
||||||
|
|
||||||
from utils import getConfig
|
from utils import getConfig
|
||||||
@@ -28,6 +29,7 @@ class ESHandler(logging.Handler):
|
|||||||
def __init__(self, *args, **kwargs):
|
def __init__(self, *args, **kwargs):
|
||||||
self.host = kwargs.get('host')
|
self.host = kwargs.get('host')
|
||||||
self.port = kwargs.get('port') or 9200
|
self.port = kwargs.get('port') or 9200
|
||||||
|
self.date = datetime.date.today()
|
||||||
self.sessionID = uuid.uuid4()
|
self.sessionID = uuid.uuid4()
|
||||||
|
|
||||||
logging.StreamHandler.__init__(self)
|
logging.StreamHandler.__init__(self)
|
||||||
@@ -35,7 +37,7 @@ class ESHandler(logging.Handler):
|
|||||||
def emit(self, record):
|
def emit(self, record):
|
||||||
self.format(record)
|
self.format(record)
|
||||||
|
|
||||||
indexURL = 'http://{}:{}/transatlantic_torrent_express/_doc'.format(self.host, self.port)
|
indexURL = 'http://{}:{}/transatlantic_torrent_express-{}/_doc'.format(self.host, self.port, self.date.strftime('%Y.%m.%d'))
|
||||||
doc = {
|
doc = {
|
||||||
'severity': record.levelname,
|
'severity': record.levelname,
|
||||||
'message': record.message,
|
'message': record.message,
|
||||||
|
|||||||
Reference in New Issue
Block a user