forked from bonovoxly/coinmarketcap-exporter
-
Notifications
You must be signed in to change notification settings - Fork 0
/
coinmarketcap.py
56 lines (51 loc) · 2.11 KB
/
coinmarketcap.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
from prometheus_client import start_http_server, Metric, REGISTRY
import argparse
import json
import logging
import requests
import sys
import time
# logging setup
log = logging.getLogger('coinmarketcap-exporter')
log.setLevel(logging.INFO)
ch = logging.StreamHandler(sys.stdout)
ch.setLevel(logging.INFO)
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
ch.setFormatter(formatter)
log.addHandler(ch)
class CoinCollector():
def __init__(self):
self.endpoint = 'https://api.coinmarketcap.com/v1/ticker/'
def collect(self):
# query the api
r = requests.get(self.endpoint)
request_time = r.elapsed.total_seconds()
log.info('elapsed time -' + str(request_time))
response = json.loads(r.content.decode('UTF-8'))
# setup the metric
metric = Metric('coinmarketcap_response_time', 'Total time for the coinmarketcap API to respond.', 'summary')
# add the response time as a metric
metric.add_sample('coinmarketcap_response_time', value=float(request_time), labels={'name': 'coinmarketcap.com'})
yield metric
metric = Metric('coin_market', 'coinmarketcap metric values', 'gauge')
for each in response:
for that in ['rank', 'price_usd', 'price_btc', '24h_volume_usd', 'market_cap_usd', 'available_supply', 'total_supply', 'percent_change_1h', 'percent_change_24h', 'percent_change_7d']:
coinmarketmetric = '_'.join(['coin_market', that])
if each[that] is not None:
metric.add_sample(coinmarketmetric, value=float(each[that]), labels={'id': each['id'], 'name': each['name'], 'symbol': each['symbol']})
yield metric
if __name__ == '__main__':
try:
parser = argparse.ArgumentParser(
description=__doc__,
formatter_class=argparse.ArgumentDefaultsHelpFormatter)
parser.add_argument('--port', nargs='?', const=9101, help='The TCP port to listen on. Defaults to 9101.', default=9101)
args = parser.parse_args()
log.info(args.port)
REGISTRY.register(CoinCollector())
start_http_server(int(args.port))
while True:
time.sleep(60)
except KeyboardInterrupt:
print(" Interrupted")
exit(0)