8.5 Plataforma de publicación

IoTBoX admite protocolos de envío personalizados a plataformas en la nube

8.5.1 Variables incorporadas

• g: Tabla global, se puede llamar y modificar en cualquier función
• publisher: Plataforma de publicación actual, el tipo es Publisher

8.5.2 Arquitectura básica

El código mínimo es el siguiente

--@return number 初始化返回 固定为0
---@description Se llama cuando el programa se inicia por primera vez
---@usage Se utiliza para inicializar el contenido requerido para la publicación, incluyendo protocolo de envío, configuración de protocolo, etc.
function Init()
    return 0
end

---@return number 推送状态 0为OK,非零为推送失败
---@description Se llama internamente en un bucle para enviar datos
---@usage Enviar datos después de Format
function Push()
    return 0
end

---@return number 格式化返回 固定返回0
---@description Se llama internamente en un bucle para formateo de datos
---@usage El sistema llama a esta función para formateo de datos antes de enviar los datos
function Format()
    return 0
end

---@return number 连接状态 0表示连接成功，其他值表示未连接
---@description El sistema llamará a la función de conexión cuando la conexión falle
---@usage Esta función se llamará automáticamente
function Connect()
    return 0
end

---@return number 连接状态 0表示连接成功，其他值表示未连接
---@description Se llama internamente en un bucle para verificar el estado de conexión MQTT
---@usage Llame repetidamente a esta función en escenarios donde se necesite asegurar la conexión MQTT para monitorear el estado de conexión
function CheckConnect()
    return 0
end

1. IoTBoX llamará a la función Init durante la inicialización para completar la inicialización de la plataforma de publicación
2. Después de la inicialización, se llamará a la función Connect para conectarse a la plataforma en la nube. Devuelve 0 si la conexión tiene éxito, distinto de 0 si falla
3. IoTBoX llama internamente a la función CheckConnect en un bucle. Si devuelve distinto de 0, llamará a la función Connect para reconectar
4. IoTBoX ejecutará la función Format en cada ciclo de envío para formatear los datos recopilados, devuelve 0
5. Después del formateo, se llamará a la función Push para enviar datos a la plataforma en la nube. Devuelve 0 si el envío tiene éxito, distinto de 0 si falla

8.5.3 Ejemplo de conexión a plataforma MQTT

function on_connect()
    -- Manejar después de la conexión
    box.log("info","mqtt服务器已连接")
    g.mqtt:Subscribe(g.control_topic,0)
    init={};
    init["device_id"] = publisher.gateway_id;
    init["device_type"] = "gateway";
    init["online"] = true;
    g.mqtt:PushMessage(cjson.encode(init), g.data_topic,0,0);
end

function on_disconnect()
    -- Manejar después de la desconexión
    box.log("warn","mqtt服务器离线")
end

function on_message(topic,message)
    -- Manejar datos recibidos
    box.log("debug",topic,message)
end

function Init()
    -- Inicializar envío
    g.control_topic="control_topic"
    g.data_topic="data_topic"
    g.mqtt=MqttClient()
    g.mqtt.address=config.address;
    if config.username ~=nil and #config.username~=0 then
        g.mqtt.username=config.username
    end
    if config.password ~=nil and #config.password~=0 then
        g.mqtt.password=config.password
    end
    g.mqtt.client_id=box.fingerprint;
    g.mqtt.on_connect=on_connect
    g.mqtt.on_disconnect=on_disconnect
    g.mqtt.on_message=on_message
    will={}
    will["device_id"] = publisher.gateway_id
    will["device_type"] = "gateway";
    will["online"] = false;
    g.mqtt.will_msg=cjson.encode(will)
    g.mqtt.will_topic=g.data_topic
    return 0
end

function Push()
    box.log("debug","aaaaa  push")
    return g.mqtt:PushMessage(cjson.encode(publisher:GetMessage()),g.data_topic,0,0)
end


function Format()
    box.log("debug","aaaaa  format")
    local origin_messages=publisher:GetOriginMessage()
    local result_messages={}
    for i, origin_message in ipairs(origin_messages) do
        local one_message={}
        one_message.device_id=origin_message.device_id
        one_message.device_name=origin_message.device_name
        one_message.device_state=origin_message.device_state
        one_message.device_type=origin_message.device_type
        one_message.ts=origin_message.ts
        one_message.values={}
        local index=1
        for name, value in pairs(origin_message.values) do
            value.name = name;
            value.id = nil;
            one_message.values[index]=value
            index=index+1
        end
        result_messages[i]=one_message
    end
    publisher:SetMessage(result_messages)
    return 0
end
--- 2
function Connect()
    return g.mqtt:Connect()
end
function CheckConnect()
    local r= g.mqtt:CheckConnect()
    return r
end