{"id":1077805,"date":"2025-01-08T12:05:42","date_gmt":"2025-01-08T04:05:42","guid":{"rendered":"https:\/\/docs.pingcode.com\/ask\/ask-ask\/1077805.html"},"modified":"2025-01-08T12:05:45","modified_gmt":"2025-01-08T04:05:45","slug":"python-%e5%a6%82%e4%bd%95%e5%ae%9e%e7%8e%b0%e6%9c%9f%e8%b4%a7%e5%ae%9e%e6%97%b6%e6%95%b0%e6%8d%ae-2","status":"publish","type":"post","link":"https:\/\/docs.pingcode.com\/ask\/1077805.html","title":{"rendered":"python \u5982\u4f55\u5b9e\u73b0\u671f\u8d27\u5b9e\u65f6\u6570\u636e"},"content":{"rendered":"

\"python<\/p>\n

\u901a\u8fc7\u83b7\u53d6\u5b9e\u65f6\u6570\u636e\u3001\u4f7f\u7528WebSocket\u8fde\u63a5\u3001API\u8c03\u7528\u7b49\u65b9\u5f0f\u53ef\u4ee5\u5b9e\u73b0Python\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u3002<\/strong> \u5728\u672c\u6587\u4e2d\uff0c\u6211\u4eec\u5c06\u8be6\u7ec6\u4ecb\u7ecd\u5982\u4f55\u901a\u8fc7\u8fd9\u4e9b\u65b9\u6cd5\u6765\u5b9e\u73b0\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u83b7\u53d6\u3002<\/p>\n<\/p>\n

\n

\u4e00\u3001\u901a\u8fc7API\u8c03\u7528\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e<\/h3>\n<\/p>\n

API\uff08\u5e94\u7528\u7a0b\u5e8f\u7f16\u7a0b\u63a5\u53e3\uff09\u662f\u83b7\u53d6\u5b9e\u65f6\u671f\u8d27\u6570\u636e\u7684\u5e38\u89c1\u65b9\u6cd5\u4e4b\u4e00\u3002\u8bb8\u591a\u671f\u8d27\u4ea4\u6613\u6240\u548c\u6570\u636e\u63d0\u4f9b\u5546\u90fd\u63d0\u4f9bAPI\u63a5\u53e3\uff0c\u901a\u8fc7\u8fd9\u4e9b\u63a5\u53e3\u53ef\u4ee5\u65b9\u4fbf\u5730\u83b7\u53d6\u671f\u8d27\u7684\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n<\/p>\n

1.1 \u4f7f\u7528\u671f\u8d27\u4ea4\u6613\u6240\u63d0\u4f9b\u7684API<\/h4>\n<\/p>\n

\u8bb8\u591a\u671f\u8d27\u4ea4\u6613\u6240\u63d0\u4f9b\u514d\u8d39\u7684API\u63a5\u53e3\u6765\u83b7\u53d6\u5b9e\u65f6\u6570\u636e\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u7b80\u5355\u7684\u793a\u4f8b\uff0c\u5c55\u793a\u5982\u4f55\u4f7f\u7528Python\u8c03\u7528API\u6765\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\uff1a<\/p>\n<\/p>\n

import requests<\/p>\n
def get_futures_data(symbol):<\/p>\n
    url = f'https:\/\/api.exchange.com\/v1\/market\/{symbol}\/ticker'<\/p>\n
    response = requests.get(url)<\/p>\n
    data = response.json()<\/p>\n
    return data<\/p>\n
symbol = 'BTC-USD'<\/p>\n
data = get_futures_data(symbol)<\/p>\n
print(data)<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d\uff0c\u6211\u4eec\u4f7f\u7528\u4e86requests<\/code>\u5e93\u6765\u53d1\u9001HTTP GET\u8bf7\u6c42\uff0c\u5e76\u83b7\u53d6\u7279\u5b9a\u671f\u8d27\u5408\u7ea6\u7684\u5b9e\u65f6\u6570\u636e\u3002\u4f60\u53ef\u4ee5\u6839\u636e\u5177\u4f53\u7684API\u6587\u6863\u8c03\u6574URL\u548c\u53c2\u6570\u3002<\/p>\n<\/p>\n
1.2 \u4f7f\u7528\u7b2c\u4e09\u65b9\u6570\u636e\u63d0\u4f9b\u5546\u7684API<\/h4>\n<\/p>\n
\u9664\u4e86\u4ea4\u6613\u6240\uff0c\u8bb8\u591a\u7b2c\u4e09\u65b9\u6570\u636e\u63d0\u4f9b\u5546\u4e5f\u63d0\u4f9b\u4e86\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684API\u670d\u52a1\u3002\u4f8b\u5982\uff0cAlpha Vantage\u3001Quandl\u7b49\u3002\u4ee5\u4e0b\u662f\u4f7f\u7528Alpha Vantage API\u83b7\u53d6\u671f\u8d27\u6570\u636e\u7684\u793a\u4f8b\uff1a<\/p>\n<\/p>\n
import requests<\/p>\n
def get_alpha_vantage_data(symbol, api_key):<\/p>\n
    url = f'https:\/\/www.alphavantage.co\/query?function=TIME_SERIES_INTRADAY&symbol={symbol}&interval=1min&apikey={api_key}'<\/p>\n
    response = requests.get(url)<\/p>\n
    data = response.json()<\/p>\n
    return data<\/p>\n
symbol = 'ES=F'<\/p>\n
api_key = 'your_api_key_here'<\/p>\n
data = get_alpha_vantage_data(symbol, api_key)<\/p>\n
print(data)<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u4e8c\u3001\u4f7f\u7528WebSocket\u8fde\u63a5\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e<\/h3>\n<\/p>\n
WebSocket\u662f\u4e00\u79cd\u5728\u5355\u4e2aTCP\u8fde\u63a5\u4e0a\u8fdb\u884c\u5168\u53cc\u5de5\u901a\u4fe1\u7684\u534f\u8bae\uff0c\u9002\u5408\u4e8e\u9700\u8981\u9891\u7e41\u6216\u5b9e\u65f6\u66f4\u65b0\u6570\u636e\u7684\u5e94\u7528\u3002\u901a\u8fc7WebSocket\u8fde\u63a5\uff0c\u53ef\u4ee5\u5b9e\u73b0\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u9ad8\u6548\u4f20\u8f93\u3002<\/p>\n<\/p>\n
2.1 \u4f7f\u7528WebSocket\u5e93<\/h4>\n<\/p>\n
Python\u63d0\u4f9b\u4e86\u591a\u4e2aWebSocket\u5e93\uff0c\u4ee5\u4e0b\u662f\u4f7f\u7528websocket-client<\/code>\u5e93\u8fde\u63a5\u5230WebSocket\u670d\u52a1\u5668\u5e76\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u793a\u4f8b\uff1a<\/p>\n<\/p>\n
import websocket<\/p>\n
import json<\/p>\n
def on_message(ws, message):<\/p>\n
    data = json.loads(message)<\/p>\n
    print(data)<\/p>\n
def on_error(ws, error):<\/p>\n
    print(error)<\/p>\n
def on_close(ws):<\/p>\n
    print("### closed ###")<\/p>\n
def on_open(ws):<\/p>\n
    subscribe_message = {<\/p>\n
        "type": "subscribe",<\/p>\n
        "symbol": "BTC-USD"<\/p>\n
    }<\/p>\n
    ws.send(json.dumps(subscribe_message))<\/p>\n
websocket.enableTrace(True)<\/p>\n
ws = websocket.WebSocketApp("wss:\/\/api.exchange.com\/v1\/marketdata",<\/p>\n
                            on_message=on_message,<\/p>\n
                            on_error=on_error,<\/p>\n
                            on_close=on_close)<\/p>\n
ws.on_open = on_open<\/p>\n
ws.run_forever()<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d\uff0c\u6211\u4eec\u4f7f\u7528websocket-client<\/code>\u5e93\u8fde\u63a5\u5230WebSocket\u670d\u52a1\u5668\uff0c\u5e76\u5728\u8fde\u63a5\u6210\u529f\u540e\u53d1\u9001\u8ba2\u9605\u6d88\u606f\u6765\u83b7\u53d6\u7279\u5b9a\u671f\u8d27\u5408\u7ea6\u7684\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n<\/p>\n
2.2 \u4f7f\u7528\u7b2c\u4e09\u65b9WebSocket\u670d\u52a1<\/h4>\n<\/p>\n
\u4e00\u4e9b\u6570\u636e\u63d0\u4f9b\u5546\u63d0\u4f9b\u4e86WebSocket\u670d\u52a1\u6765\u63a8\u9001\u5b9e\u65f6\u6570\u636e\u3002\u4f8b\u5982\uff0cBinance\u671f\u8d27\u6570\u636e\u53ef\u4ee5\u901a\u8fc7WebSocket\u83b7\u53d6\uff1a<\/p>\n<\/p>\n
import websocket<\/p>\n
import json<\/p>\n
def on_message(ws, message):<\/p>\n
    data = json.loads(message)<\/p>\n
    print(data)<\/p>\n
def on_error(ws, error):<\/p>\n
    print(error)<\/p>\n
def on_close(ws):<\/p>\n
    print("### closed ###")<\/p>\n
def on_open(ws):<\/p>\n
    subscribe_message = {<\/p>\n
        "method": "SUBSCRIBE",<\/p>\n
        "params": [<\/p>\n
            "btcusdt@aggTrade"<\/p>\n
        ],<\/p>\n
        "id": 1<\/p>\n
    }<\/p>\n
    ws.send(json.dumps(subscribe_message))<\/p>\n
websocket.enableTrace(True)<\/p>\n
ws = websocket.WebSocketApp("wss:\/\/fstream.binance.com\/ws",<\/p>\n
                            on_message=on_message,<\/p>\n
                            on_error=on_error,<\/p>\n
                            on_close=on_close)<\/p>\n
ws.on_open = on_open<\/p>\n
ws.run_forever()<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d\uff0c\u6211\u4eec\u8fde\u63a5\u5230Binance\u7684WebSocket\u670d\u52a1\uff0c\u5e76\u8ba2\u9605btcusdt<\/code>\u5408\u7ea6\u7684\u5b9e\u65f6\u4ea4\u6613\u6570\u636e\u3002<\/p>\n<\/p>\n
\u4e09\u3001\u4f7f\u7528\u6570\u636e\u6d41\u5e73\u53f0\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e<\/h3>\n<\/p>\n
\u6570\u636e\u6d41\u5e73\u53f0\uff08\u5982Kafka\u3001Kinesis\u7b49\uff09\u53ef\u4ee5\u5904\u7406\u548c\u4f20\u8f93\u5927\u91cf\u7684\u5b9e\u65f6\u6570\u636e\uff0c\u975e\u5e38\u9002\u5408\u7528\u4e8e\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u83b7\u53d6\u548c\u5904\u7406\u3002<\/p>\n<\/p>\n
3.1 \u4f7f\u7528Apache Kafka<\/h4>\n<\/p>\n
Apache Kafka\u662f\u4e00\u4e2a\u5206\u5e03\u5f0f\u6d41\u5904\u7406\u5e73\u53f0\uff0c\u652f\u6301\u9ad8\u541e\u5410\u91cf\u7684\u6570\u636e\u6d41\u5904\u7406\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528Python\u8fde\u63a5Kafka\u5e76\u6d88\u8d39\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u793a\u4f8b\uff1a<\/p>\n<\/p>\n
from kafka import KafkaConsumer<\/p>\n
import json<\/p>\n
def consume_kafka_data(topic):<\/p>\n
    consumer = KafkaConsumer(<\/p>\n
        topic,<\/p>\n
        bootstrap_servers=['localhost:9092'],<\/p>\n
        auto_offset_reset='earliest',<\/p>\n
        enable_auto_commit=True,<\/p>\n
        group_id='my-group',<\/p>\n
        value_deserializer=lambda x: json.loads(x.decode('utf-8'))<\/p>\n
    )<\/p>\n
    for message in consumer:<\/p>\n
        data = message.value<\/p>\n
        print(data)<\/p>\n
topic = 'futures_data'<\/p>\n
consume_kafka_data(topic)<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d\uff0c\u6211\u4eec\u521b\u5efa\u4e86\u4e00\u4e2aKafka\u6d88\u8d39\u8005\uff0c\u5e76\u8ba2\u9605\u4e86futures_data<\/code>\u4e3b\u9898\u6765\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n<\/p>\n
3.2 \u4f7f\u7528AWS Kinesis<\/h4>\n<\/p>\n
AWS Kinesis\u662f\u4e00\u4e2a\u5b8c\u5168\u6258\u7ba1\u7684\u6570\u636e\u6d41\u5e73\u53f0\uff0c\u652f\u6301\u5b9e\u65f6\u6570\u636e\u7684\u6536\u96c6\u3001\u5904\u7406\u548c\u5206\u6790\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528Python\u8fde\u63a5Kinesis\u5e76\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u793a\u4f8b\uff1a<\/p>\n<\/p>\n
import boto3<\/p>\n
import json<\/p>\n
def consume_kinesis_data(stream_name):<\/p>\n
    client = boto3.client('kinesis')<\/p>\n
    shard_iterator = client.get_shard_iterator(<\/p>\n
        StreamName=stream_name,<\/p>\n
        ShardId='shardId-000000000000',<\/p>\n
        ShardIteratorType='LATEST'<\/p>\n
    )['ShardIterator']<\/p>\n
    while True:<\/p>\n
        response = client.get_records(ShardIterator=shard_iterator, Limit=10)<\/p>\n
        records = response['Records']<\/p>\n
        for record in records:<\/p>\n
            data = json.loads(record['Data'])<\/p>\n
            print(data)<\/p>\n
        shard_iterator = response['NextShardIterator']<\/p>\n
stream_name = 'futures_data_stream'<\/p>\n
consume_kinesis_data(stream_name)<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d\uff0c\u6211\u4eec\u4f7f\u7528\u4e86AWS\u7684boto3<\/code>\u5e93\u6765\u8fde\u63a5Kinesis\uff0c\u5e76\u83b7\u53d6futures_data_stream<\/code>\u6d41\u4e2d\u7684\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n<\/p>\n
\u56db\u3001\u4f7f\u7528\u722c\u866b\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e<\/h3>\n<\/p>\n
\u5728\u67d0\u4e9b\u60c5\u51b5\u4e0b\uff0c\u671f\u8d27\u6570\u636e\u6ca1\u6709\u63d0\u4f9bAPI\u6216WebSocket\u670d\u52a1\uff0c\u8fd9\u65f6\u53ef\u4ee5\u4f7f\u7528\u722c\u866b\u6280\u672f\u4ece\u7f51\u9875\u4e0a\u6293\u53d6\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n<\/p>\n
4.1 \u4f7f\u7528BeautifulSoup\u6293\u53d6\u7f51\u9875\u6570\u636e<\/h4>\n<\/p>\n
BeautifulSoup\u662f\u4e00\u4e2a\u7528\u4e8e\u89e3\u6790HTML\u548cXML\u6587\u6863\u7684Python\u5e93\uff0c\u53ef\u4ee5\u65b9\u4fbf\u5730\u4ece\u7f51\u9875\u4e2d\u63d0\u53d6\u6570\u636e\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528BeautifulSoup\u6293\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u793a\u4f8b\uff1a<\/p>\n<\/p>\n
import requests<\/p>\n
from bs4 import BeautifulSoup<\/p>\n
def get_futures_data(url):<\/p>\n
    response = requests.get(url)<\/p>\n
    soup = BeautifulSoup(response.content, 'html.parser')<\/p>\n
    data = soup.find_all('div', class_='data-class')<\/p>\n
    for item in data:<\/p>\n
        print(item.text)<\/p>\n
url = 'https:\/\/www.example.com\/futures'<\/p>\n
get_futures_data(url)<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d\uff0c\u6211\u4eec\u53d1\u9001\u4e86\u4e00\u4e2aHTTP GET\u8bf7\u6c42\uff0c\u5e76\u4f7f\u7528BeautifulSoup\u89e3\u6790\u54cd\u5e94\u5185\u5bb9\uff0c\u4ece\u4e2d\u63d0\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n<\/p>\n
4.2 \u4f7f\u7528Selenium\u6a21\u62df\u6d4f\u89c8\u5668\u64cd\u4f5c<\/h4>\n<\/p>\n
Selenium\u662f\u4e00\u4e2a\u7528\u4e8e\u81ea\u52a8\u5316Web\u6d4f\u89c8\u5668\u64cd\u4f5c\u7684Python\u5e93\uff0c\u53ef\u4ee5\u6a21\u62df\u7528\u6237\u5728\u6d4f\u89c8\u5668\u4e2d\u7684\u64cd\u4f5c\uff0c\u9002\u7528\u4e8e\u52a8\u6001\u7f51\u9875\u6570\u636e\u6293\u53d6\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528Selenium\u6293\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u793a\u4f8b\uff1a<\/p>\n<\/p>\n
from selenium import webdriver<\/p>\n
from selenium.webdriver.common.by import By<\/p>\n
from selenium.webdriver.chrome.service import Service<\/p>\n
def get_futures_data(url):<\/p>\n
    service = Service('\/path\/to\/chromedriver')<\/p>\n
    driver = webdriver.Chrome(service=service)<\/p>\n
    driver.get(url)<\/p>\n
    data = driver.find_elements(By.CLASS_NAME, 'data-class')<\/p>\n
    for item in data:<\/p>\n
        print(item.text)<\/p>\n
    driver.quit()<\/p>\n
url = 'https:\/\/www.example.com\/futures'<\/p>\n
get_futures_data(url)<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d\uff0c\u6211\u4eec\u4f7f\u7528Selenium\u6253\u5f00\u4e00\u4e2a\u6d4f\u89c8\u5668\u7a97\u53e3\uff0c\u5e76\u4ece\u9875\u9762\u4e2d\u63d0\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n<\/p>\n
\u4e94\u3001\u6570\u636e\u5b58\u50a8\u4e0e\u53ef\u89c6\u5316<\/h3>\n<\/p>\n
\u5728\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u540e\uff0c\u901a\u5e38\u9700\u8981\u5c06\u6570\u636e\u5b58\u50a8\u5230\u6570\u636e\u5e93\u6216\u5176\u4ed6\u5b58\u50a8\u7cfb\u7edf\u4e2d\uff0c\u4ee5\u4fbf\u540e\u7eed\u5206\u6790\u548c\u5904\u7406\u3002\u540c\u65f6\uff0c\u53ef\u4ee5\u4f7f\u7528\u53ef\u89c6\u5316\u5de5\u5177\u6765\u5c55\u793a\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n<\/p>\n
5.1 \u6570\u636e\u5b58\u50a8<\/h4>\n<\/p>\n
\u53ef\u4ee5\u9009\u62e9\u9002\u5408\u7684\u6570\u636e\u5b58\u50a8\u7cfb\u7edf\u6765\u5b58\u50a8\u671f\u8d27\u5b9e\u65f6\u6570\u636e\uff0c\u4f8b\u5982MySQL\u3001MongoDB\u3001InfluxDB\u7b49\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u5c06\u671f\u8d27\u6570\u636e\u5b58\u50a8\u5230MySQL\u6570\u636e\u5e93\u7684\u793a\u4f8b\uff1a<\/p>\n<\/p>\n
import mysql.connector<\/p>\n
def store_data_to_mysql(data):<\/p>\n
    connection = mysql.connector.connect(<\/p>\n
        host='localhost',<\/p>\n
        user='yourusername',<\/p>\n
        password='yourpassword',<\/p>\n
        database='futures_data'<\/p>\n
    )<\/p>\n
    cursor = connection.cursor()<\/p>\n
    query = "INSERT INTO futures (symbol, price, volume) VALUES (%s, %s, %s)"<\/p>\n
    cursor.execute(query, (data['symbol'], data['price'], data['volume']))<\/p>\n
    connection.commit()<\/p>\n
    cursor.close()<\/p>\n
    connection.close()<\/p>\n
data = {'symbol': 'BTC-USD', 'price': 50000, 'volume': 10}<\/p>\n
store_data_to_mysql(data)<\/p>\n
<\/code><\/pre>\n<\/p>\n
5.2 \u6570\u636e\u53ef\u89c6\u5316<\/h4>\n<\/p>\n
\u53ef\u4ee5\u4f7f\u7528Matplotlib\u3001Plotly\u7b49\u53ef\u89c6\u5316\u5e93\u6765\u5c55\u793a\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528Matplotlib\u7ed8\u5236\u671f\u8d27\u5b9e\u65f6\u4ef7\u683c\u56fe\u8868\u7684\u793a\u4f8b\uff1a<\/p>\n<\/p>\n
import matplotlib.pyplot as plt<\/p>\n
import matplotlib.animation as animation<\/p>\n
fig, ax = plt.subplots()<\/p>\n
xdata, ydata = [], []<\/p>\n
def update(frame):<\/p>\n
    xdata.append(frame['timestamp'])<\/p>\n
    ydata.append(frame['price'])<\/p>\n
    ax.clear()<\/p>\n
    ax.plot(xdata, ydata)<\/p>\n
    ax.set_title('Futures Price Over Time')<\/p>\n
    ax.set_xlabel('Time')<\/p>\n
    ax.set_ylabel('Price')<\/p>\n
ani = animation.FuncAnimation(fig, update, frames=get_realtime_data, blit=False)<\/p>\n
plt.show()<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5728\u8fd9\u4e2a\u793a\u4f8b\u4e2d\uff0c\u6211\u4eec\u4f7f\u7528Matplotlib\u7684\u52a8\u753b\u529f\u80fd\u5b9e\u65f6\u66f4\u65b0\u671f\u8d27\u4ef7\u683c\u56fe\u8868\u3002<\/p>\n<\/p>\n
\u603b\u7ed3<\/h3>\n<\/p>\n
\u901a\u8fc7API\u8c03\u7528\u3001WebSocket\u8fde\u63a5\u3001\u6570\u636e\u6d41\u5e73\u53f0\u3001\u722c\u866b\u7b49\u591a\u79cd\u65b9\u6cd5\uff0c\u53ef\u4ee5\u5b9e\u73b0Python\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u83b7\u53d6\u548c\u5904\u7406\u3002\u9009\u62e9\u5408\u9002\u7684\u65b9\u6cd5\u548c\u5de5\u5177\uff0c\u7ed3\u5408\u6570\u636e\u5b58\u50a8\u548c\u53ef\u89c6\u5316\u6280\u672f\uff0c\u53ef\u4ee5\u6784\u5efa\u4e00\u4e2a\u5b8c\u6574\u7684\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7cfb\u7edf\u3002\u5e0c\u671b\u672c\u6587\u5bf9\u60a8\u6709\u6240\u5e2e\u52a9\u3002<\/p>\n<\/p>\n
\u76f8\u5173\u95ee\u7b54FAQs\uff1a<\/strong><\/h2>\n
 \u5982\u4f55\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684API\u63a8\u8350\uff1f<\/strong>
\u83b7\u53d6\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u7684\u5e38\u7528\u65b9\u6cd5\u662f\u901a\u8fc7API\u3002\u5e02\u9762\u4e0a\u6709\u591a\u79cd\u91d1\u878d\u6570\u636e\u63d0\u4f9b\u5546\uff0c\u5982Alpha Vantage\u3001Quandl\u3001Interactive Brokers\u7b49\uff0c\u63d0\u4f9b\u671f\u8d27\u6570\u636e\u7684API\u3002\u9009\u62e9API\u65f6\u5e94\u8003\u8651\u5176\u6570\u636e\u7684\u66f4\u65b0\u9891\u7387\u3001\u8986\u76d6\u7684\u5e02\u573a\u4ee5\u53ca\u8d39\u7528\u7b49\u56e0\u7d20\u3002\u5927\u591a\u6570API\u4f1a\u63d0\u4f9b\u6587\u6863\u6307\u5bfc\uff0c\u7528\u6237\u53ef\u4ee5\u901a\u8fc7\u7f16\u7a0b\u8bed\u8a00\uff08\u5982Python\uff09\u8c03\u7528\u76f8\u5e94\u7684\u63a5\u53e3\u83b7\u53d6\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n
\u4f7f\u7528Python\u83b7\u53d6\u671f\u8d27\u6570\u636e\u7684\u5e93\u6709\u54ea\u4e9b\uff1f<\/strong>
\u5728Python\u4e2d\uff0c\u6709\u591a\u4e2a\u5e93\u53ef\u4ee5\u5e2e\u52a9\u7528\u6237\u83b7\u53d6\u671f\u8d27\u6570\u636e\u3002\u4f8b\u5982\uff0cpandas<\/code>\u548cnumpy<\/code>\u7528\u4e8e\u6570\u636e\u5904\u7406\uff0crequests<\/code>\u53ef\u7528\u4e8e\u53d1\u9001HTTP\u8bf7\u6c42\uff0c\u83b7\u53d6\u6570\u636e\u3002ccxt<\/code>\u5e93\u4e13\u6ce8\u4e8e\u52a0\u5bc6\u8d27\u5e01\u4ea4\u6613\u6240\uff0c\u4f46\u4e5f\u652f\u6301\u4e00\u4e9b\u671f\u8d27\u5e02\u573a\u3002\u6b64\u5916\uff0cTA-Lib<\/code>\u53ef\u7528\u4e8e\u6280\u672f\u5206\u6790\uff0c\u5e2e\u52a9\u7528\u6237\u5206\u6790\u83b7\u53d6\u7684\u5b9e\u65f6\u6570\u636e\u3002<\/p>\n
\u5982\u4f55\u5904\u7406\u548c\u5206\u6790\u83b7\u53d6\u5230\u7684\u671f\u8d27\u5b9e\u65f6\u6570\u636e\uff1f<\/strong>
\u83b7\u53d6\u5b9e\u65f6\u6570\u636e\u540e\uff0c\u53ef\u4ee5\u4f7f\u7528pandas<\/code>\u5e93\u5bf9\u6570\u636e\u8fdb\u884c\u6e05\u6d17\u548c\u5904\u7406\u3002\u901a\u8fc7\u7ed8\u5236\u56fe\u8868\uff08\u5982\u4f7f\u7528matplotlib<\/code>\u6216seaborn<\/code>\uff09\u6765\u53ef\u89c6\u5316\u6570\u636e\u8d8b\u52bf\uff0c\u6216\u8005\u4f7f\u7528scikit-learn<\/code>\u8fdb\u884c\u673a\u5668\u5b66\u4e60<\/a>\u5efa\u6a21\u3002\u6280\u672f\u5206\u6790\u6307\u6807\u5982\u5747\u7ebf\u3001\u76f8\u5bf9\u5f3a\u5f31\u6307\u6570\uff08RSI\uff09\u7b49\uff0c\u80fd\u591f\u5e2e\u52a9\u7528\u6237\u66f4\u597d\u5730\u7406\u89e3\u5e02\u573a\u52a8\u6001\uff0c\u5e76\u505a\u51fa\u51b3\u7b56\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"\u901a\u8fc7\u83b7\u53d6\u5b9e\u65f6\u6570\u636e\u3001\u4f7f\u7528WebSocket\u8fde\u63a5\u3001API\u8c03\u7528\u7b49\u65b9\u5f0f\u53ef\u4ee5\u5b9e\u73b0Python\u671f\u8d27\u5b9e\u65f6\u6570\u636e\u3002 \u5728\u672c\u6587\u4e2d\uff0c\u6211 […]","protected":false},"author":3,"featured_media":1077815,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[37],"tags":[],"acf":[],"_links":{"self":[{"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/posts\/1077805"}],"collection":[{"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/comments?post=1077805"}],"version-history":[{"count":"1","href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/posts\/1077805\/revisions"}],"predecessor-version":[{"id":1077818,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/posts\/1077805\/revisions\/1077818"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/media\/1077815"}],"wp:attachment":[{"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/media?parent=1077805"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/categories?post=1077805"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/tags?post=1077805"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}