手搓Clawdbot远程遥控实战，全球A十大风口技术解读，爬取万条招聘数据揭秘行情

from flask import Flask
from flask_socketio import SocketIO, emit
import paho.mqtt.client as mqtt

app = Flask(__name__)
socketio = SocketIO(app, cors_allowed_origins='*')

# MQTT 客户端
mqtt_client = mqtt.Client()
mqtt_client.connect('localhost', 1883)

@socketio.on('command')
def handle_command(data):
    # 将指令转为 MQTT 消息，广播给所有订阅设备
    mqtt_client.publish('clawdbot/control', payload=data['dir'])
    emit('ack', {'status': 'sent', 'dir': data['dir']}, broadcast=False)

@socketio.on('telemetry')
def handle_telemetry(data):
    # 接收机器人上报的遥测数据，转发给所有前端
    emit('telemetry', data, broadcast=True)

if __name__ == '__main__':
    socketio.run(app, host='0.0.0.0', port=5000)

import paho.mqtt.client as mqtt
import time
import random

def on_message(client, userdata, msg):
    direction = msg.payload.decode()
    print(f'执行指令: {direction}')
    # 模拟运动逻辑（此处可接 GPIO 控制）
    time.sleep(0.5)
    # 上报遥测数据（电量、坐标）
    tele = {'battery': random.randint(80, 100), 'pos': (random.randint(0,10), random.randint(0,10))}
    client.publish('clawdbot/telemetry', str(tele))

client = mqtt.Client()
client.on_message = on_message
client.connect('your-server', 1883)
client.subscribe('clawdbot/control')
client.loop_forever()

// React 组件示例
const sendCommand = (dir) => {
  socket.emit('command', { dir });
};
// 监听遥测
socket.on('telemetry', (data) => {
  setBattery(data.battery);
  setPosition(data.pos);
});

# 简化示例：仅展示解析逻辑
def parse_job(html):
    soup = BeautifulSoup(html, 'html.parser')
    title = soup.find('h3', class_='job-title').text
    salary = soup.find('span', class_='salary').text
    skills = [tag.text for tag in soup.find_all('span', class_='skill-tag')]
    direction = classify(title)  # 自定义分类器
    return {'title': title, 'salary': salary, 'skills': skills, 'direction': direction}