highperfocused/nostr-search
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

merge into: highperfocused:traefik
Branches Tags
highperfocused:main
highperfocused:traefik
...
pull from: highperfocused:main
Branches Tags
highperfocused:main
highperfocused:traefik

2 Commits
traefik ... main

Author SHA1 Message Date
PascalR
30225cca42
Merge pull request #4 from layer-systems/index_improvements 
index improvements
 2023-10-09 01:04:55 +02:00
mroxso
6b29a1da1f index improvements 2023-10-09 01:04:00 +02:00
1 changed files with 4 additions and 1 deletions
Show Stats Expand all files Collapse all files

5
main.py
View File

@ -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"):