105 lines
3.4 KiB
Python
105 lines
3.4 KiB
Python
import redis
|
||
import requests
|
||
import pymysql
|
||
from datetime import datetime
|
||
|
||
# ---------------- Redis 配置 ----------------
|
||
REDIS_HOST = "127.0.0.1"
|
||
REDIS_PORT = 6379
|
||
REDIS_DB = 7
|
||
|
||
# ---------------- MySQL 配置 ----------------
|
||
MYSQL_HOST = "127.0.0.1"
|
||
MYSQL_PORT = 25600
|
||
MYSQL_USER = "root"
|
||
MYSQL_PASS = "123456"
|
||
MYSQL_DB = "pool"
|
||
TABLE_NAME = "`vipor.net`"
|
||
|
||
# ---------------- 连接 Redis ----------------
|
||
r = redis.Redis(host=REDIS_HOST, port=REDIS_PORT, db=REDIS_DB, decode_responses=True)
|
||
|
||
# ---------------- 连接 MySQL ----------------
|
||
conn = pymysql.connect(host=MYSQL_HOST, port=MYSQL_PORT, user=MYSQL_USER,
|
||
password=MYSQL_PASS, database=MYSQL_DB, charset='utf8mb4')
|
||
cursor = conn.cursor()
|
||
|
||
# ---------------- 从 Redis 获取矿池配置 ----------------
|
||
# 格式: pool_name:wallet:COIN:ALGORITHM
|
||
keys = r.keys("vipor.net:*")
|
||
|
||
def get_half_hour_time():
|
||
"""返回最近半点时间"""
|
||
now = datetime.now()
|
||
minute = 30 if now.minute >= 30 else 0
|
||
return now.replace(minute=minute, second=0, microsecond=0)
|
||
|
||
def fetch_vipor_data(pool_name, coin, wallet, algorithm, api_pool):
|
||
url = f"https://restapi.vipor.net/api/pools/{api_pool}/miners/{wallet}"
|
||
try:
|
||
resp = requests.get(url, timeout=10)
|
||
resp.raise_for_status()
|
||
data = resp.json()
|
||
|
||
# 优先 performance.workers
|
||
workers = data.get("performance", {}).get("workers")
|
||
if not workers:
|
||
workers = data.get("workers") or data.get("miners") or {}
|
||
|
||
if not workers:
|
||
print(f"{coin} | {api_pool} | {wallet} ⚠ 当前没有任何在线矿机")
|
||
return
|
||
|
||
for miner, info in workers.items():
|
||
hashrate = info.get("hashrate", 0) or 0
|
||
hashrate_mhs = hashrate / 1_000_000 # 转为 MH/s
|
||
|
||
# 插入 MySQL
|
||
sql = f"""INSERT INTO {TABLE_NAME}
|
||
(datetime, pool_name, wallet, miner, hashrate, coin, algorithm)
|
||
VALUES (%s, %s, %s, %s, %s, %s, %s)"""
|
||
cursor.execute(sql, (
|
||
get_half_hour_time(),
|
||
pool_name, # 这里使用 Redis key 的第一部分
|
||
wallet,
|
||
miner,
|
||
hashrate_mhs,
|
||
coin,
|
||
algorithm
|
||
))
|
||
conn.commit()
|
||
|
||
print(f"{coin} | {api_pool} | {miner}: {hashrate_mhs:.2f} MH/s 写入成功")
|
||
|
||
except requests.exceptions.HTTPError as e:
|
||
print(f"{coin} | {api_pool} | {wallet} 请求失败 HTTP 错误:", e)
|
||
except Exception as e:
|
||
print(f"{coin} | {api_pool} | {wallet} 请求失败:", e)
|
||
|
||
|
||
if __name__ == "__main__":
|
||
for key in keys:
|
||
parts = key.split(":")
|
||
if len(parts) != 4:
|
||
continue
|
||
pool_name, wallet, coin, algorithm = parts
|
||
|
||
# 构造普通和 solo pool 名（用于请求 API，不影响存入数据库的 pool_name）
|
||
api_pools = []
|
||
if coin == "NEXA":
|
||
api_pools = ["nexa", "nexa_solo"]
|
||
elif coin == "XEL":
|
||
api_pools = ["xelis", "xelis_solo"]
|
||
elif coin == "XNA":
|
||
api_pools = ["neurai", "neurai_solo"]
|
||
elif coin == "CLORE":
|
||
api_pools = ["clore", "clore_solo"]
|
||
else:
|
||
api_pools = ["default", "default_solo"]
|
||
|
||
for api_pool in api_pools:
|
||
fetch_vipor_data(pool_name, coin, wallet, algorithm, api_pool)
|
||
|
||
# 关闭连接
|
||
cursor.close()
|
||
conn.close() |