示例代码

from fanhua_cloud import FanhuaCloud

# 初始化客户端
client = FanhuaCloud(
    product_key="your_product_key",
    device_name="your_device_name",
    device_secret="your_device_secret"
)

# 连接设备
client.connect()

# 发送数据
client.publish_data({
    "temperature": 25.6,
    "humidity": 60
})

# 接收数据
@client.on_message
def handle_message(topic, payload):
    print(f"收到消息: {payload}")

const FanhuaCloud = require('fanhua-cloud');

const client = new FanhuaCloud({
    productKey: 'your_product_key',
    deviceName: 'your_device_name',
    deviceSecret: 'your_device_secret'
});

// 连接设备
client.connect();

// 定时上报数据
setInterval(() => {
    client.publishData({
        temperature: Math.random() * 30,
        humidity: Math.random() * 100
    });
}, 5000);

// 监听消息
client.on('message', (topic, payload) => {
    console.log('收到消息:', payload);
});

// 设备认证示例
const auth = {
    // 使用动态token
    getToken: async () => {
        const response = await fetch('/api/token', {
            method: 'POST',
            body: JSON.stringify({
                deviceId: 'device_001',
                timestamp: Date.now()
            })
        });
        return response.json();
    },
    
    // 验证签名
    verifySignature: (data, signature) => {
        // 实现签名验证逻辑
    }
};

// 数据处理示例
class DataProcessor {
    // 数据压缩
    compress(data) {
        // 实现数据压缩
    }
    
    // 数据过滤
    filter(data) {
        // 实现数据过滤
    }
    
    // 数据聚合
    aggregate(data) {
        // 实现数据聚合
    }
}