1.pybithumb

1)仮想通貨タグリストの取得

import pybithumb

tickers = pybithumb.get_tickers()
print(tickers)
print(len(tickers)) #실제로 거래되고 있는 가상화폐의 수 : 51

2）現在取得

price = pybithumb.get_current_price("BTC")
print(price)

import pybithumb
import time

while True:
    # tickers = pybithumb.get_tickers()
    price = pybithumb.get_current_price("BTC")
    print(price)
    time.sleep(1)

import pybithumb
import time

tickers = pybithumb.get_tickers()
for ticker in tickers:
    price = pybithumb.get_current_price(ticker)
    print(ticker, " - price : ", price)
    time.sleep(0.1)

3）取引所取引情報

detail = pybithumb.get_market_detail("BTC")
print(detail)

4）価格

orderbook = pybithumb.get_orderbook("BTC")
print(orderbook)

for k in orderbook:
    print(k)

orderbook印刷結果画面
{'timestamp': '1650196752255', 'payment_currency': 'KRW', 'order_currency': 'BTC', 'bids': [{'price': 50502000.0, 'quantity': 0.2135}, {'price': 50501000.0, 'quantity': 0.7749}, {'price': 50488000.0, 'quantity': 0.1506}, {'price': 50485000.0, 'quantity': 0.0655}, {'price': 50483000.0, 'quantity': 0.4867}], 'asks': [{'price': 50523000.0, 'quantity': 0.0745}, {'price': 50525000.0, 'quantity': 0.2177}, {'price': 50526000.0, 'quantity': 0.031}, {'price': 50527000.0, 'quantity': 0.0188}, {'price': 50534000.0, 'quantity': 0.0409}]}

-orderbookのキー値

orderbook = pybithumb.get_orderbook("BTC")
print(orderbook['payment_currency'])
print(orderbook['order_currency'])
ms = int(orderbook['timestamp'])
dt = datetime.datetime.fromtimestamp(ms/1000)
print(dt)
print(orderbook['bids'])
print(orderbook['asks'])

orderbook = pybithumb.get_orderbook("BTC")

bids = orderbook['bids']
asks = orderbook['asks']

for bid in bids:
    price = bid['price']
    quant = bid['quantity']
    print('매수호가 : ', price, '매수잔량 : ', quant)
    
for ask in asks:#각각의 가격과 잔고는 'price', 'quantity'라는 키에 저장된 딕셔너리형태
    print(ask)

5)複数の仮想通貨に関する情報を一度に取得

all = pybithumb.get_orderbook("ALL")
for k, v in all.items():
    print(k, v)

all = pybithumb.get_current_price("ALL")
for ticker, data in all.items() :
     print(ticker, data['closing_price'])

6）異常処理

while True:
    price = pybithumb.get_current_price("BTC")
    try:
        print(price/10) # price=None이 되는 경우 에러발생함
    except:
        print("에러", price)
    time.sleep(0.2)

2.上昇場alime

1）移動平均で上昇・下降場を区分する

2）取引所過去相場獲得

import pybithumb

btc = pybithumb.get_ohlcv("BTC")
print(btc) #DataFrame 객체 출력

import pybithumb

btc = pybithumb.get_ohlcv("BTC")
c = btc['close']
print(c)#Series 객체 출력

3）移動平均計算

import pybithumb

btc = pybithumb.get_ohlcv("BTC")
c = btc['close']

m5 = c.rolling(5).mean()
print(m5)

4）上昇場・下降場を区別する関数を実現

前日の移動平均はどこに格納されていますか.末尾の2番目の位置

import pybithumb

df = pybithumb.get_ohlcv("BTC")
m5 = df['close'].rolling(5).mean()
last_m5 = m5[-2] #전날 이동평균

price = pybithumb.get_current_price("BTC")

if price > last_m5:
    print("상승장")
else:
    print("하락장")

5）各仮想通貨の上昇・下降傾向を判断する

import pybithumb

def bull_market(ticker):
    df = pybithumb.get_ohlcv("BTC")
    m5 = df['close'].rolling(5).mean()
    last_m5 = m5[-2]

    price = pybithumb.get_current_price("BTC")

    if price > last_m5:
        return True
    else:
        return False

tickers = pybithumb.get_tickers()
for ticker in tickers:
    is_bull = bull_market(ticker)
    if is_bull:
        print(ticker,"상승장")
    else:
        print(ticker,"하락장")

6)UI/ロードUIファイルの作成

import sys
from PyQt5.QtWidgets import *
from PyQt5 import uic

form_class = uic.loadUiType("bull.ui")[0]

class MyWindow(QMainWindow, form_class):
    def __init__(self):
        super().__init__()
        self.setupUi(self)
app = QApplication(sys.argv)
win = MyWindow()
win.show()
app.exec_()

7)立ち上がり/立ち下がりコード-QTimer verを実施する。

*仮想通貨リストの追加

Table Widgetに4行追加

import sys
from PyQt5.QtWidgets import *
from PyQt5 import uic
from PyQt5.QtCore import *

tickers = ["BTC", "ETH", "BCH", "ETC"]
form_class = uic.loadUiType("bull.ui")[0]

class MyWindow(QMainWindow, form_class):
    def __init__(self):
        super(MyWindow, self).__init__()
        self.setupUi(self)
        timer=QTimer(self)
        timer.start(500)
        timer.timeout.connect(self.timeout) #timeout 발생하면 MyWindow의 timeout 실행되도록 연결함
        
    def timeout(self):
        for i, t in enumerate(tickers):
            item = QTableWidgetItem(t) #각 티커 얻어옴
            self.tableWidget.setItem(i,0,item)
            #해당 티커의 인덱스에 맞는 위치에 추가

app = QApplication(sys.argv)
win = MyWindow()
win.show()
app.exec_()

*仮想通貨の現在価格、5日平均、上昇/下落

import sys

import pybithumb
from PyQt5.QtWidgets import *
from PyQt5 import uic
from PyQt5.QtCore import *

tickers = ["BTC", "ETH", "BCH", "ETC"]
form_class = uic.loadUiType("bull.ui")[0]

class MyWindow(QMainWindow, form_class):
    def __init__(self):
        super(MyWindow, self).__init__()
        self.setupUi(self)
        timer=QTimer(self)
        timer.start(500) #0.5초마다 내용 업데이트함
        timer.timeout.connect(self.timeout)

    def get_market_infos(self, ticker):
        df = pybithumb.get_ohlcv(ticker)
        m5 = df['close'].rolling(5).mean()
        last_m5 = m5[-2]
        price = pybithumb.get_current_price("BTC")

        state = None
        if price > last_m5:
            state = '상승장'
        else:
            state = '하락장'
        return price, last_m5, state

    def timeout(self):
        for i, t in enumerate(tickers):
            item = QTableWidgetItem(t)
            self.tableWidget.setItem(i,0,item)

            price, last_m5, state = self.get_market_infos(t)
            self.tableWidget.setItem(i, 1, QTableWidgetItem(str(price)))
            self.tableWidget.setItem(i, 2, QTableWidgetItem(str(last_m5)))
            self.tableWidget.setItem(i, 3, QTableWidgetItem(str(state)))
			
app = QApplication(sys.argv)
win = MyWindow()
win.show()
app.exec_()

8)立ち上がり/立ち下がりコード-スレッドverを実装する。

import sys
import pybithumb
from PyQt5.QtWidgets import *
from PyQt5 import uic
from PyQt5.QtCore import *

tickers = ["BTC", "ETH", "BCH", "ETC"]
form_class = uic.loadUiType("bull.ui")[0]

class Worker(QThread):#스레드 상속 클래스
    finished = pyqtSignal(dict) #사용자 정의 시그널 생성

    def run(self):#스레드 실행 시 수행되는 코드
        while True:
            data = {}

            for ticker in tickers:
                data[ticker] = self.get_market_infos(ticker)

            self.finished.emit(data)#finished라는 이벤트를 발생시킴
            self.msleep(500) #0.5초 슬립

    def get_market_infos(self, ticker):
        try:
            df = pybithumb.get_ohlcv(ticker)
            m5 = df['close'].rolling(5).mean()
            last_m5 = m5[-2]

            price = pybithumb.get_current_price("BTC")

            state = None
            if price > last_m5:
                state = '상승장'
            else:
                state = '하락장'
            return (price, last_m5, state)
        except:
            return (None, None,None)


class MyWindow(QMainWindow, form_class):
    def __init__(self):
        super(MyWindow, self).__init__()
        self.setupUi(self)
        self.tableWidget.setRowCount(len(tickers))
        self.worker = Worker()
        self.worker.finished.connect(self.update_table_widget)
        self.worker.start()
    @pyqtSlot(dict)
    def update_table_widget(self, data):
        try:
            for i, t in data.items():
                index = tickers.index(t)
                self.tableWidget.setItem(index,0,QTableWidgetItem(t))
                self.tableWidget.setItem(index, 1, QTableWidgetItem(str(i[0]))) #현재가
                self.tableWidget.setItem(index, 2, QTableWidgetItem(str(i[1]))) #5일 이동평균
                self.tableWidget.setItem(index, 3, QTableWidgetItem(str(i[2]))) #상승/하락장
        except:
            pass
app = QApplication(sys.argv)
win = MyWindow()
win.show()
app.exec_()