From 6b29a1da1fb8b05017ef181b410ffa991f2ddcbc Mon Sep 17 00:00:00 2001 From: mroxso Date: Mon, 9 Oct 2023 01:04:00 +0200 Subject: [PATCH] index improvements --- main.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/main.py b/main.py index 17282a2..0ede3d5 100644 --- a/main.py +++ b/main.py @@ -3,6 +3,7 @@ import os import websockets import json from elasticsearch import Elasticsearch +from datetime import datetime async def relay_websockets(inputWebsocket, kinds, es): while True: @@ -15,7 +16,9 @@ async def relay_websockets(inputWebsocket, kinds, es): del event[1] print("Sending event " + str(event[1]['id']) + " (kind: "+str(event[1]['kind'])+") to elasticsearch") # send event to elasticsearch - resp = es.index(index="nostr", id=str(event[1]['id']), document=event[1]) + index_name = "nostr-" + datetime.today().strftime('%Y-%m-%d') + event_timestamp = datetime.fromtimestamp(event[1]['created_at']) + resp = es.index(index=index_name, id=str(event[1]['id']), document={**event[1], "@timestamp": event_timestamp}) if(resp['result'] != "created"): print("Failed to send event to elasticsearch: "+str(resp)) elif(event[0] == "EOSE"):