pinecrypt/pinecrypt-gateway-exporter
2
1
Fork 0
Code Issues 2 Pull Requests Projects Activity

Clean up metrics

Browse Source
This commit is contained in:
Lauri Võsandi 2021-06-14 22:38:46 +03:00
parent a37d841bdd
commit 8849cfe27a
2 changed files with 15 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Dockerfile
View File

@ -1,5 +1,5 @@
FROM python FROM python
MAINTAINER Pinecrypt Labs <info@pinecrypt.com> MAINTAINER Pinecrypt Labs <info@pinecrypt.com>
RUN pip install motor sanic RUN pip install sanic aiohttp
ADD exporter.py /exporter.py ADD exporter.py /exporter.py
CMD /exporter.py CMD /exporter.py

25
exporter.py
View File

@ -1,32 +1,28 @@
#!/usr/bin/env python #!/usr/bin/env python
import aiohttp
import asyncio import asyncio
import os import os
import re
from collections import Counter from collections import Counter
from motor.motor_asyncio import AsyncIOMotorClient
from sanic import Sanic, response, exceptions from sanic import Sanic, response, exceptions
app = Sanic("exporter") app = Sanic("exporter")
MONGO_URI = os.getenv("MONGO_URI", "mongodb://127.0.0.1:27017/default") PREFIX = "pinecrypt_gateway_"
PROMETHEUS_BEARER_TOKEN = os.getenv("PROMETHEUS_BEARER_TOKEN") PROMETHEUS_BEARER_TOKEN = os.getenv("PROMETHEUS_BEARER_TOKEN")
if not PROMETHEUS_BEARER_TOKEN: if not PROMETHEUS_BEARER_TOKEN:
raise ValueError("No PROMETHEUS_BEARER_TOKEN specified") raise ValueError("No PROMETHEUS_BEARER_TOKEN specified")
@app.listener("before_server_start") async def wrap(i):
async def setup_db(app, loop):
app.ctx.db = AsyncIOMotorClient(MONGO_URI).get_default_database()
async def wrap(i, prefix="pinecrypt_gateway_"):
metrics_seen = set() metrics_seen = set()
async for name, tp, value, labels in i: async for name, tp, value, labels in i:
if name not in metrics_seen: if name not in metrics_seen:
yield "# TYPE %s %s" % (name, tp) yield "# TYPE %s %s" % (PREFIX + name, tp)
metrics_seen.add(name) metrics_seen.add(name)
yield "%s%s %d" % ( yield "%s%s %d" % (
prefix + name, PREFIX + name,
("{%s}" % ",".join(["%s=\"%s\"" % j for j in labels.items()]) if labels else ""), ("{%s}" % ",".join(["%s=\"%s\"" % j for j in labels.items()]) if labels else ""),
value) value)
@ -73,13 +69,20 @@ async def openvpn_stats(port, service):
async def view_export(request): async def view_export(request):
if request.token != PROMETHEUS_BEARER_TOKEN: if request.token != PROMETHEUS_BEARER_TOKEN:
raise exceptions.Forbidden("Invalid bearer token") raise exceptions.Forbidden("Invalid bearer token")
coll = app.ctx.db["certidude_certificates"]
async def streaming_fn(response): async def streaming_fn(response):
for i in exporter_stats(), openvpn_stats(7505, "openvpn-udp"), openvpn_stats(7506, "openvpn-tcp"): for i in exporter_stats(), openvpn_stats(7505, "openvpn-udp"), openvpn_stats(7506, "openvpn-tcp"):
async for line in wrap(i): async for line in wrap(i):
await response.write(line + "\n") await response.write(line + "\n")
async with aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=5)) as session:
for port in (4001, 5001, 8001, 9001):
async with session.get("http://127.0.0.1:%d/metrics" % port) as upstream_response:
async for line in upstream_response.content:
if not re.match("(# (HELP|TYPE) )?(pinecrypt|goredns)_", line.decode("ascii")):
continue
await response.write(line)
return response.stream(streaming_fn, content_type="text/plain") return response.stream(streaming_fn, content_type="text/plain")
app.run(port=3001) app.run(port=3001)