Python自动化交易项目：如何从交易指标网页向Android应用发指令？

一、从交易指标网站获取数据 #

1. 优先使用官方API #

如果目标网站提供公开API，这是最稳定的获取方式，直接用requests库调用即可：

import requests

# 示例：假设API需要身份验证
headers = {
    "Authorization": "Bearer YOUR_API_KEY",
    "Content-Type": "application/json"
}
response = requests.get("https://目标网站API地址/指标数据", headers=headers)
if response.status_code == 200:
    data = response.json()
    # 此处编写数据解析与处理逻辑
else:
    print(f"请求失败，状态码: {response.status_code}")

2. 无公开API时使用网页爬取 #

若网站未提供API，可通过网页解析获取数据，用BeautifulSoup处理HTML内容：

import requests
from bs4 import BeautifulSoup

# 模拟浏览器请求头，避免被反爬拦截
headers = {
    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36"
}
response = requests.get("https://目标交易指标网站地址", headers=headers)
if response.status_code == 200:
    soup = BeautifulSoup(response.text, "html.parser")
    # 示例：通过CSS选择器定位目标指标元素
    indicator_value = soup.select_one(".指标对应的CSS类名").text.strip()
    print(f"获取到的指标值: {indicator_value}")
else:
    print(f"爬取失败，状态码: {response.status_code}")

注意：爬取前务必查看网站的robots.txt规则，避免频繁请求触发反爬机制，必要时可搭配代理IP池分散请求来源。

二、向Android端发送特定指令 #

1. HTTP接口方案（简单易实现） #

Android端搭建轻量HTTP服务，Python端通过requests发送指令：

• Python端代码：

import requests

# Android设备的局域网IP和服务端口
android_service_url = "http://192.168.1.100:8080/trade-command"
# 封装要发送的指令数据
command_payload = {"action": "buy", "symbol": "BTC", "amount": 0.01}
response = requests.post(android_service_url, json=command_payload)
if response.status_code == 200:
    print("指令发送成功")
else:
    print("指令发送失败")

• Android端核心逻辑（Kotlin示例）：

// 使用OkHttp搭建简易HTTP服务
val server = OkHttpServer()
server.listen(8080) { request ->
    if (request.method == "POST" && request.path == "/trade-command") {
        val commandJson = request.body.string()
        // 解析JSON指令并执行对应交易操作
        return@listen Response.Builder()
            .code(200)
            .body("指令接收成功")
            .build()
    }
    Response.Builder().code(404).build()
}

2. MQTT协议方案（适合实时通信场景） #

MQTT是轻量级消息协议，适合设备间低延迟的指令推送：

• Python端代码（依赖paho-mqtt库）：

import paho.mqtt.client as mqtt

# 连接MQTT broker（可自行搭建或使用公共服务）
client = mqtt.Client()
client.connect("MQTT broker地址", 1883, 60)
# 向指定主题发布交易指令
client.publish("trade/commands", '{"action": "sell", "symbol": "ETH"}')
client.disconnect()

• Android端集成Eclipse Paho等MQTT客户端，订阅trade/commands主题即可接收指令。

3. WebSocket方案（双向实时交互） #

需要双向通信时选择WebSocket：

• Python端代码（依赖websockets库）：

import asyncio
import websockets

async def send_trade_command():
    async with websockets.connect("ws://192.168.1.100:8080/trade-ws") as websocket:
        # 发送取消订单指令
        await websocket.send('{"action": "cancel", "order_id": "12345"}')
        # 接收Android端的处理反馈
        feedback = await websocket.recv()
        print(f"Android端反馈: {feedback}")

asyncio.run(send_trade_command())

• Android端用OkHttp实现WebSocket客户端，建立连接后即可接收并处理指令。

内容的提问来源于stack exchange，提问作者Lord SC11