Python 프로젝트 » 비트코인 자동매매

h1. 실시간 데이터 출력(기본)

h3. 소스코드

<pre>

import multiprocessing as mp

import websockets

import asyncio

import json

import sys

from PyQt5.QtWidgets import *

from PyQt5.QtCore import *

async def upbit_ws_client(q):

    uri = "wss://api.upbit.com/websocket/v1"

    async with websockets.connect(uri) as websocket:

        subscribe_fmt = [

            {"ticket":"test"},

            {

                "type":"ticker",

                "codes":["KRW-BTC"],

                "isOnlyRealtime":True

            },

            {"format":"SIMPLE"}

        ]

        subscribe_data = json.dumps(subscribe_fmt)

        await websocket.send(subscribe_data)

        while True:

            data = await websocket.recv()

            data = json.loads(data)

            q.put(data)

async def main(q):

    await upbit_ws_client(q)

def producer(q):

    asyncio.run(main(q))

class Consumer(QThread):

    poped = pyqtSignal(dict)

    def __init__(self, q):

        super().__init__()

        self.q = q

    def run(self):

        while True:

            if not self.q.empty():

                data = q.get()

                self.poped.emit(data)

class MyWindow(QMainWindow):

    def __init__(self, q):

        super().__init__()

        self.setGeometry(200, 200, 400, 200)

        self.setWindowTitle("Upbit Websocket")

        # thread for data consumer

        self.consumer = Consumer(q)

        self.consumer.poped.connect(self.print_data)

        self.consumer.start()

        # widget

        self.label = QLabel("Bitcoin: ", self)

        self.label.move(10, 10)

        # QLineEdit

        self.line_edit = QLineEdit(" ", self)

        self.line_edit.resize(150, 30)

        self.line_edit.move(100, 10)

    @pyqtSlot(dict)

    def print_data(self, data):

        current_price = int(data.get('tp'))

        self.line_edit.setText(format(current_price, ",d"))

if __name__ == "__main__":

    q = mp.Queue()

    p = mp.Process(name="Producer", target=producer, args=(q,), daemon=True)

    p.start()

    # Main process

    app = QApplication(sys.argv)

    mywindow = MyWindow(q)

    mywindow.show()

    app.exec_()

</pre>

h3. 결과

!clipboard-202502101143-pjsmq.png!