Este tema utiliza el archivo de demostración./demos/mqtt_upload_basic_demo.c del Link SDK para C como ejemplo para describir cómo llamar a las API del Link SDK y cargar archivos en IoT Platform mediante MQTT, lo que reduce el consumo de recursos de hardware y los costos de desarrollo.
Contexto
Para obtener una descripción general de la función de carga de archivos, consulte File Upload Overview.
La función de carga de archivos se basa en conexiones MQTT. Para ver ejemplos de código de conexión MQTT, consulte Connect to IoT Platform over MQTT.
Paso 1: Inicializar la carga de archivos
-
Agregue los archivos de encabezado.
…… …… #include "aiot_mqtt_api.h" #include "aiot_mqtt_upload_api.h" #include "core_crc64.h" …… -
Configure las dependencias subyacentes y la salida de registros.
/* A collection of system adaptation functions located in the portfiles/aiot_port/ directory. */ extern aiot_sysdep_portfile_t g_aiot_sysdep_portfile; /* The server certificate located in external/ali_ca_cert.c. */ extern const char *ali_ca_cert; /* The log callback, where SDK logs are output. */ static int32_t demo_state_logcb(int32_t code, char *message) { printf("%s", message); return 0; } -
Llame a aiot_mqtt_upload_init para crear una instancia de cliente de carga de archivos e inicializar sus parámetros predeterminados.
mqtt_handle = aiot_mqtt_upload_init();
Paso 2: Configurar la carga de archivos
Llame a aiot_mqtt_upload_setopt para configurar las siguientes opciones.
-
Asocie el identificador de conexión MQTT.
ImportanteAntes de configurar los parámetros de la función de carga de archivos, asegúrese de haber configurado las credenciales de autenticación del dispositivo y los parámetros relacionados. Configure MQTT connection parameters.
Las solicitudes de carga de archivos utilizan conexiones MQTT. Asocie el identificador de conexión MQTT con esta opción.
void *up_handle = aiot_mqtt_upload_init(); aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_MQTT_HANDLE, mqtt_handle); -
(Opcional)
Configure los parámetros de carga de archivos.
-
Código de ejemplo:
uint32_t rsp_timeout = 2000; aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_RSP_TIMEOUT_MS, &rsp_timeout); uint32_t rety_count = 5; aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_RETRY_COUNT, &rety_count); uint32_t block_size = 1024; aiot_mqtt_upload_setopt(up_handle, AIOT_MQTT_UPLOADOPT_DEFAULT_BLOCK_SIZE, &block_size); -
Parámetros:
Parámetro
Descripción
rsp_timeout
El tiempo de espera para retransmitir cada fragmento de datos, en milisegundos.
Predeterminado: 5,000 ms (5 segundos). Establezca 0 para usar el valor predeterminado.
Valor de ejemplo: 2,000 ms.
AIOT_MQTT_UPLOADOPT_RSP_TIMEOUT_MS
Establece el tiempo de espera para retransmitir cada fragmento de datos durante la carga del archivo.
rety_count
El número de intentos de reintento tras un tiempo de espera agotado.
Predeterminado: 10.
Valor de ejemplo: 5.
AIOT_MQTT_UPLOADOPT_RETRY_COUNT
Establece el número de intentos de reintento tras un tiempo de espera agotado durante la carga del archivo.
block_size
El tamaño máximo de cada fragmento de datos, en bytes.
Rango válido: 256–131,072. Predeterminado: 2,048 bytes.
Valor de ejemplo: 1,024 bytes.
AIOT_MQTT_UPLOADOPT_DEFAULT_BLOCK_SIZE
Establece el tamaño máximo de cada fragmento de datos enviado durante la carga del archivo.
-
(Opcional) Paso 3: Calcular la suma de comprobación CRC64
De forma predeterminada, el protocolo realiza un cálculo CRC16 en cada fragmento de datos. Opcionalmente, puede usar CRC64 para validar el archivo completo. El SDK incluye una biblioteca en C para el cálculo de CRC64.
El siguiente código calcula la suma de comprobación CRC64 para un archivo:
uint64_t crc = mqtt_upload_get_file_crc64(MQTT_UPLOAD_FILE_NAME);
Paso 4: Solicitar una carga de archivo
-
Llame a aiot_mqtt_upload_open_stream para enviar una solicitud de carga de archivo a IoT Platform.
ImportanteAl cargar un archivo, no llame a aiot_mqtt_upload_open_stream varias veces para el mismo archivo. Si falla una carga, puede reenviar la solicitud para reanudarla.
Al cargar diferentes archivos, puede llamar a aiot_mqtt_upload_open_stream varias veces. El SDK admite la carga simultánea de varios archivos.
-
Código de ejemplo:
-
Defina los tamaños y nombres de los archivos:
#define MQTT_UPLOAD_FILE_SIZE (2 * 1024) #define MQTT_UPLOAD_FILE_NAME ("mqttuploadfile001.txt") #define MQTT_UPLOAD_FILE_SIZE2 (1 * 1024 + 127) #define MQTT_UPLOAD_FILE_NAME2 ("mqttuploadfile002.txt") -
Envíe solicitudes para cargar los archivos:
uint32_t test_userdata = 100; aiot_mqtt_upload_open_stream(up_handle, MQTT_UPLOAD_FILE_NAME, MQTT_UPLOAD_FILE_SIZE, AIOT_MQTT_UPLOAD_FILE_MODE_OVERWRITE, &crc, mqtt_upload_read_data_handler, &test_userdata); mqtt_upload_create_upload_file(MQTT_UPLOAD_FILE_NAME2, MQTT_UPLOAD_FILE_SIZE2); aiot_mqtt_upload_open_stream(up_handle, MQTT_UPLOAD_FILE_NAME2, MQTT_UPLOAD_FILE_SIZE2, AIOT_MQTT_UPLOAD_FILE_MODE_OVERWRITE, NULL, mqtt_upload_read_data_handler, NULL);
-
-
Descripción del código de ejemplo:
-
El código de ejemplo llama a esta API para cargar dos archivos simultáneamente:
mqttuploadfile001.txtymqttuploadfile002.txt.Importante-
Los nombres de archivo tienen las siguientes restricciones:
Contener solo dígitos, letras, guiones bajos (_) y puntos (.).
Comenzar con un dígito o una letra.
Tener una longitud máxima de 100 bytes.
El tamaño máximo del archivo es de 16 MB.
-
El archivo
mqttuploadfile001.txtutiliza validación CRC64 y pasa el parámetrouserdata.El archivo
mqttuploadfile002.txtno utiliza validación CRC64 y no se pasa ningún parámetrouserdata.-
El código de ejemplo utiliza la directiva de procesamiento overwrite. La siguiente tabla describe las directivas de procesamiento disponibles.
Directiva
Descripción
overwrite
Directiva predeterminada. IoT Platform elimina el archivo existente con el mismo nombre y conserva únicamente el archivo recién cargado.
append
Cuando un dispositivo envía una solicitud de carga de archivo, IoT Platform devuelve información sobre cualquier archivo existente con el mismo nombre. El dispositivo puede entonces:
-
Si el archivo existente se cargó de forma incompleta, el dispositivo puede reanudar la carga.
NotaIoT Platform conserva las cargas incompletas solo durante 24 horas.
-
Si el archivo ya se cargó por completo, el dispositivo debe usar la directiva de sobrescritura o cambiar el nombre del archivo local antes de volver a cargarlo.
reject
IoT Platform devuelve un código de error que indica que el archivo ya existe y rechaza la solicitud de carga.
-
-
-
IoT Platform responde a la solicitud de carga de archivo y activa una devolución de llamada en el dispositivo.
En la devolución de llamada, el SDK lee el contenido del archivo o los datos de memoria en fragmentos y realiza un cálculo CRC16 en cada uno.
ImportanteDurante la transferencia por fragmentos, cada fragmento de datos no debe exceder el valor de
AIOT_MQTT_UPLOADOPT_DEFAULT_BLOCK_SIZE. Excepto el último fragmento, cada uno debe tener como mínimo 256 bytes.La siguiente función de devolución de llamada
mqtt_upload_read_data_handlerlee los datos del archivo en fragmentos:int32_t mqtt_upload_read_data_handler(const aiot_mqtt_upload_recv_t *packet, uint8_t *data, uint32_t size, void *userdata) { int32_t read_len = 0; if (userdata != NULL) { uint32_t *test_userdata = (uint32_t *)userdata; printf("test_userdata:%d\r\n", *test_userdata); } if (packet == NULL) { return 0; } if (packet->desc.code == UPLOAD_FILE_OK) { if (data != NULL && size != 0) { uint32_t read_size = size; FILE *fp; char* file_name = packet->desc.file_name; fp = fopen(file_name, "r"); uint32_t offset = packet->desc.file_offset; fseek(fp, offset, SEEK_SET); printf("Open %s read at: %d\r\n", file_name, offset); read_len = fread(data, sizeof(uint8_t), read_size, fp); printf("Read_len: %d\r\n", read_len); fclose(fp); } } else { printf("Error code:%d, message:%s\r\n", packet->desc.code, packet->desc.message); } return read_len; } -
(Opcional)
Para cancelar una carga en curso, llame a aiot_mqtt_upload_cancel_stream.
Referencia de la API: aiot_mqtt_upload_cancel_stream.
Paso 5: Gestionar el estado de la carga
Durante la carga del archivo, llame a aiot_mqtt_upload_process en un bucle para comprobar el estado de la carga:
while(1) {
aiot_mqtt_upload_result_t result = aiot_mqtt_upload_process(up_handle);
if (result.code == STATE_MQTT_UPLOAD_FINISHED) {
/* Upload successful. */
printf("MQTT Upload file(%s) success\r\n", result.file_name);
uploaded_file++;
if (uploaded_file == 2) {
break;
}
} else if (result.code == STATE_MQTT_UPLOAD_FAILED ||
result.code == STATE_MQTT_UPLOAD_FAILED_TIMEOUT ||
result.code == STATE_MQTT_UPLOAD_CANCEL_FAILED ) {
/* Upload failed. */
printf("MQTT Upload file(%s) failed,res:-0x%.4X\r\n", result.file_name, -result.code);
/* Destroy the MQTT UPLOAD instance. */
} else if (result.code == STATE_MQTT_UPLOAD_CANCEL_SUCCESS) {
printf("MQTT Upload file(%s) cancel success,res:-0x%.4X\r\n", result.file_name, -result.code);
} else if (result.code == STATE_MQTT_UPLOAD_FAILED_WHOLE_CHECK) {
printf("MQTT Upload file(%s) whole file md5 failed,res:-0x%.4X\r\n", result.file_name, -result.code);
}
sleep(1);
}
Paso 6: Desinicializar la carga de archivos
Llame a aiot_mqtt_upload_deinit para destruir la instancia de cliente de carga de archivos y liberar recursos:
aiot_mqtt_upload_deinit(&up_handle);
Registros del lado del dispositivo
Consulte los resultados de ejecución en el lado del dispositivo.
-
Registros de conexión:
Una conexión exitosa del dispositivo a IoT Platform genera el siguiente registro:
[1637138922.457][LK-0313] MQTT user calls aiot_mqtt_connect api, connect [1637138922.457][LK-032A] mqtt host: iot-******.iot-as-mqtt.unify.aliyuncs.com [1637138922.457][LK-0317] user name: LightSwitch&a18wP****** [1637138922.457][LK-0318] password: 2AE57DEEAADE002064F87DEC55EE2EDD2A1996E44BA8F5622507D1EFD6****** success to establish tcp, fd=5 local port: 57139 [1637138922.488][LK-1000] establish mbedtls connection with server(host='iot-******.iot-as-mqtt.unify.aliyuncs.com', port=[1883]) [1637138922.507][LK-1000] success to establish mbedtls connection, (cost 45247 bytes in total, max used 47983 bytes) [1637138922.654][LK-0313] MQTT connect success in 197 ms AIOT_MQTTEVT_CONNECT -
Suscripciones a temas de carga de archivos:
[1637138922.654][LK-2013] aiot_mqtt_upload_init init [1637138922.654][LK-0309] sub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/init_reply [1637138922.654][LK-0309] sub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/send_reply [1637138922.654][LK-0309] sub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/cancel_reply -
Registros de solicitudes de carga de archivos:
El dispositivo envía solicitudes de carga para dos archivos:
Nombre del archivo
Tamaño (bytes)
Validación CRC64
mqttuploadfile001.txt
2048
Sí
mqttuploadfile002.txt
1151
No
[1637138922.655][LK-0309] pub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/init [LK-030A] > 7B 22 69 64 22 3A 22 31 22 2C 22 70 61 72 61 6D | {"id":"1","params" [LK-030A] > 73 22 3A 7B 22 66 69 6C 65 4E 61 6D 65 22 3A 22 | :{"fileName":" [LK-030A] > 6D 71 74 74 75 70 6C 6F 61 64 66 69 6C 65 30 30 | mqttuploadfile001.txt" [LK-030A] > 31 2E 74 78 74 22 2C 22 66 69 6C 65 53 69 7A 65 | ,"fileSize [LK-030A] > 22 3A 32 30 34 38 2C 22 63 6F 6E 66 6C 69 63 74 | ":2048,"conflictStrategy" [LK-030A] > 53 74 72 61 74 65 67 79 22 3A 22 6F 76 65 72 77 | :"overwrite" [LK-030A] > 72 69 74 65 22 2C 22 66 69 63 4D 6F 64 65 22 3A | ,"ficMode": [LK-030A] > 22 63 72 63 36 34 22 2C 22 66 69 63 56 61 6C 75 | "crc64","ficValue" [LK-030A] > 65 22 3A 22 66 34 38 66 34 33 37 64 35 35 64 34 | :"f48f437d55** [LK-030A] > 37 31 34 63 22 7D 7D | ****"}} [1637138922.655][LK-0309] pub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/init [LK-030A] > 7B 22 69 64 22 3A 22 32 22 2C 22 70 61 72 61 6D | {"id":"2","params" [LK-030A] > 73 22 3A 7B 22 66 69 6C 65 4E 61 6D 65 22 3A 22 | :{"fileName":" [LK-030A] > 6D 71 74 74 75 70 6C 6F 61 64 66 69 6C 65 30 30 | mqttuploadfile002.txt" [LK-030A] > 32 2E 74 78 74 22 2C 22 66 69 6C 65 53 69 7A 65 | ,"fileSize [LK-030A] > 22 3A 31 31 35 31 2C 22 63 6F 6E 66 6C 69 63 74 | ":1151,"conflictStrategy" [LK-030A] > 53 74 72 61 74 65 67 79 22 3A 22 6F 76 65 72 77 | :"overwrite" [LK-030A] > 72 69 74 65 22 7D 7D | }} -
Registros de respuesta de carga de archivos:
Registros de respuesta para los dos archivos:
-
mqttuploadfile001.txt
[1637138923.214][LK-0309] pub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/init_reply [LK-030A] < 7B 22 63 6F 64 65 22 3A 32 30 30 2C 22 64 61 74 | {"code":200,"data" [LK-030A] < 61 22 3A 7B 22 66 69 6C 65 4E 61 6D 65 22 3A 22 | :{"fileName":" [LK-030A] < 6D 71 74 74 75 70 6C 6F 61 64 66 69 6C 65 30 30 | mqttuploadfile001.txt" [LK-030A] < 31 2E 74 78 74 22 2C 22 75 70 6C 6F 61 64 49 64 | ,"uploadId [LK-030A] < 22 3A 22 6B 54 48 76 63 47 45 31 78 58 56 48 33 | ":"kTHvcGE1xXVH3 [LK-030A] < 46 79 44 4C 34 4C 55 30 31 30 32 30 30 22 2C 22 | FyDL4LU******"," [LK-030A] < 6F 66 66 73 65 74 22 3A 30 2C 22 66 69 6C 65 53 | offset":0,"fileSize" [LK-030A] < 69 7A 65 22 3A 32 30 34 38 2C 22 63 6F 6E 66 6C | :2048,"conflictStrategy" [LK-030A] < 69 63 74 53 74 72 61 74 65 67 79 22 3A 22 6F 76 | :"overwrite"} [LK-030A] < 65 72 77 72 69 74 65 22 7D 2C 22 69 64 22 3A 22 | ,"id":"1" [LK-030A] < 31 22 2C 22 6D 65 73 73 61 67 65 22 3A 22 73 75 | ,"message": [LK-030A] < 63 63 65 73 73 22 7D | "success"} test_userdata:100 Open mqttuploadfile001.txt read at: 0 -
mqttuploadfile002.txt
[LK-030A] < 7B 22 63 6F 64 65 22 3A 32 30 30 2C 22 64 61 74 | {"code":200,"data" [LK-030A] < 61 22 3A 7B 22 66 69 6C 65 4E 61 6D 65 22 3A 22 | :{"fileName":" [LK-030A] < 6D 71 74 74 75 70 6C 6F 61 64 66 69 6C 65 30 30 | mqttuploadfile002.txt" [LK-030A] < 32 2E 74 78 74 22 2C 22 75 70 6C 6F 61 64 49 64 | ,"uploadId [LK-030A] < 22 3A 22 6B 6F 48 54 45 4B 46 34 59 58 31 6E 61 | ":"koHTEKF4YX1na [LK-030A] < 46 30 74 49 33 43 35 30 31 30 32 30 30 22 2C 22 | F0tI3C5******"," [LK-030A] < 6F 66 66 73 65 74 22 3A 30 2C 22 66 69 6C 65 53 | offset":0,"fileSize" [LK-030A] < 69 7A 65 22 3A 31 31 35 31 2C 22 63 6F 6E 66 6C | :1151, [LK-030A] < 69 63 74 53 74 72 61 74 65 67 79 22 3A 22 6F 76 | "conflictStrategy": [LK-030A] < 65 72 77 72 69 74 65 22 7D 2C 22 69 64 22 3A 22 | "overwrite"},"id":" [LK-030A] < 32 22 2C 22 6D 65 73 73 61 67 65 22 3A 22 73 75 | 2","message": [LK-030A] < 63 63 65 73 73 22 7D | "success"}
-
-
Registros de lectura de archivos:
Después de que IoT Platform responde y activa la devolución de llamada, los registros de lectura del archivo son:
-
mqttuploadfile001.txt
Open mqttuploadfile001.txt read at: 0 Read_len: 1024 [1637138923.215][LK-2014] Read data_len:1024[1637138923.215][LK-0309] pub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/send [LK-030A] > 00 55 7B 22 69 64 22 3A 22 34 22 2C 22 70 61 72 | .U{"id":"4","params" [LK-030A] > 61 6D 73 22 3A 7B 22 75 70 6C 6F 61 64 49 64 22 | :{"uploadId" [LK-030A] > 3A 22 6B 54 48 76 63 47 45 31 78 58 56 48 33 46 | :"kTHvcGE1xXVH3F [LK-030A] > 79 44 4C 34 4C 55 30 31 30 32 30 30 22 2C 22 6F | yDL4LU******", [LK-030A] > 66 66 73 65 74 22 3A 30 2C 22 62 53 69 7A 65 22 | "offset":0,"bSize" [LK-030A] > 3A 31 30 32 34 7D 7D 55 4E 41 56 41 4F 4F 56 4C | :1024}}UNAVAOOVL [LK-030A] > 53 43 58 4C 57 59 43 54 5A 58 45 4C 47 43 4E 57 | SCXLWYCTZXELGCNW [LK-030A] > 58 55 55 41 46 54 47 46 46 42 4D 46 48 48 54 59 | XUUAFTGFFBMFHHTY [LK-030A] > 52 59 46 58 44 49 57 45 4A 4E 50 47 46 4A 49 45 | RYFXDIWEJNPGFJIE [LK-030A] > 4E 43 55 43 50 4B 54 57 54 50 4F 4F 49 45 4B 4C | NCUCPKTWTPOOIEKL [LK-030A] > 4F 5A 54 55 55 42 4C 4B 58 5A 48 59 4D 4A 49 43 | OZTUUBLKXZHYMJIC [LK-030A] > 46 41 4E 54 49 41 59 41 46 4E 4B 4D 52 4F 43 51 | FANTIAYAFNKMROCQ [LK-030A] > 48 4F 43 56 44 59 54 51 59 57 52 4D 48 4E 42 50 | HOCVDYTQY****** ...... ...... ...... -
mqttuploadfile002.txt
Open mqttuploadfile002.txt read at: 0 Read_len: 1024 [1637138923.216][LK-2014] Read data_len:1024[1637138923.216][LK-0309] pub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/send [LK-030A] > 00 55 7B 22 69 64 22 3A 22 33 22 2C 22 70 61 72 | .U{"id":"3","params" [LK-030A] > 61 6D 73 22 3A 7B 22 75 70 6C 6F 61 64 49 64 22 | :{"uploadId" [LK-030A] > 3A 22 6B 6F 48 54 45 4B 46 34 59 58 31 6E 61 46 | :"koHTEKF4YX1naF [LK-030A] > 30 74 49 33 43 35 30 31 30 32 30 30 22 2C 22 6F | 0tI3C5******", [LK-030A] > 66 66 73 65 74 22 3A 30 2C 22 62 53 69 7A 65 22 | "offset":0,"bSize" [LK-030A] > 3A 31 30 32 34 7D 7D 55 4E 41 56 41 4F 4F 56 4C | :1024}}UNAVAOOVL [LK-030A] > 53 43 58 4C 57 59 43 54 5A 58 45 4C 47 43 4E 57 | SCXLWYCTZXELGCNW [LK-030A] > 58 55 55 41 46 54 47 46 46 42 4D 46 48 48 54 59 | XUUAFTGFFBMFHHTY [LK-030A] > 52 59 46 58 44 49 57 45 4A 4E 50 47 46 4A 49 45 | RYFXDIWEJNPGFJIE [LK-030A] > 4E 43 55 43 50 4B 54 57 54 50 4F 4F 49 45 4B 4C | NCUCPKTWTPOOIEKL [LK-030A] > 4F 5A 54 55 55 42 4C 4B 58 5A 48 59 4D 4A 49 43 | OZTUUBLKXZHYMJIC [LK-030A] > 46 41 4E 54 49 41 59 41 46 4E 4B 4D 52 4F 43 51 | FANTIAYAFNKMROCQ [LK-030A] > 48 4F 43 56 44 59 54 51 59 57 52 4D 48 4E 42 50 | HOCVDYTQYW****** ...... ...... ......
-
-
Registros de monitoreo del estado de carga:
Una vez completada la carga, IoT Platform devuelve información de estado:
-
mqttuploadfile001.txt
NotaEste archivo utiliza validación de integridad CRC64, por lo que el registro incluye el valor CRC64 validado.
[1637138924.099][LK-0309] pub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/send_reply [LK-030A] < 7B 22 63 6F 64 65 22 3A 32 30 30 2C 22 64 61 74 | {"code":200,"data" [LK-030A] < 61 22 3A 7B 22 66 69 63 56 61 6C 75 65 43 6C 69 | :{"ficValueCli [LK-030A] < 65 6E 74 22 3A 22 66 34 38 66 34 33 37 64 35 35 | ent":"f48f437d55 [LK-030A] < 64 34 37 31 34 63 22 2C 22 66 69 63 4D 6F 64 65 | ******","ficMode [LK-030A] < 22 3A 22 63 72 63 36 34 22 2C 22 75 70 6C 6F 61 | ":"crc64","uploadId" [LK-030A] < 64 49 64 22 3A 22 6B 54 48 76 63 47 45 31 78 58 | :"kTHvcGE1xX [LK-030A] < 56 48 33 46 79 44 4C 34 4C 55 30 31 30 32 30 30 | VH3FyDL4LU****** [LK-030A] < 22 2C 22 6F 66 66 73 65 74 22 3A 31 30 32 34 2C | ","offset":1024, [LK-030A] < 22 63 6F 6D 70 6C 65 74 65 22 3A 74 72 75 65 2C | "complete":true, [LK-030A] < 22 66 69 63 56 61 6C 75 65 53 65 72 76 65 72 22 | "ficValueServer" [LK-030A] < 3A 22 66 34 38 66 34 33 37 64 35 35 64 34 37 31 | :"f48f437d55**** [LK-030A] < 34 63 22 2C 22 62 53 69 7A 65 22 3A 31 30 32 34 | **","bSize":1024 [LK-030A] < 7D 2C 22 69 64 22 3A 22 36 22 2C 22 6D 65 73 73 | },"id":"6","message" [LK-030A] < 61 67 65 22 3A 22 73 75 63 63 65 73 73 22 7D | :"success"} [1637138924.099][LK-2014] Upload total size:2048 -
mqttuploadfile002.txt
[1637138923.884][LK-0309] pub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/send_reply [LK-030A] < 7B 22 63 6F 64 65 22 3A 32 30 30 2C 22 64 61 74 | {"code":200,"data" [LK-030A] < 61 22 3A 7B 22 75 70 6C 6F 61 64 49 64 22 3A 22 | :{"uploadId":" [LK-030A] < 6B 6F 48 54 45 4B 46 34 59 58 31 6E 61 46 30 74 | koHTEKF4YX1naF0t [LK-030A] < 49 33 43 35 30 31 30 32 30 30 22 2C 22 6F 66 66 | I3C5******","offset" [LK-030A] < 73 65 74 22 3A 31 30 32 34 2C 22 63 6F 6D 70 6C | :1024,"complete" [LK-030A] < 65 74 65 22 3A 74 72 75 65 2C 22 62 53 69 7A 65 | :true,"bSize [LK-030A] < 22 3A 31 32 37 7D 2C 22 69 64 22 3A 22 35 22 2C | ":127},"id":"5", [LK-030A] < 22 6D 65 73 73 61 67 65 22 3A 22 73 75 63 63 65 | "message":"success" [LK-030A] < 73 73 22 7D | } [1637138923.884][LK-2014] Upload total size:1151
-
-
Registros de salida del programa:
Una vez completada la carga, el programa cancela la suscripción a los temas relacionados y finaliza.
[1637648533.379][LK-2124] Complete upload total size:2048 MQTT Upload file(mqttuploadfile001.txt) success [1637648534.407][LK-2100] Finish upload,Deleted upload task. MQTT Upload file(mqttuploadfile002.txt) success [1637648534.407][LK-210F] aiot_mqtt_upload_deinit [1637648534.407][LK-0309] unsub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/init_reply [1637648534.408][LK-0309] unsub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/send_reply [1637648534.408][LK-0309] unsub: /sys/a18wP******/LightSwitch/thing/file/upload/mqtt/cancel_reply [1637648534.513][LK-1000] adapter_network_deinit
Registros de IoT Platform
Gestione los archivos cargados y consulte los registros de ejecución en la consola de IoT Platform.
-
Para ver los archivos cargados, vaya a Device Management > Devices. Haga clic en View para el dispositivo objetivo y luego seleccione la pestaña File Management.
La lista de archivos muestra el nombre del archivo, el tamaño, la hora de carga y las operaciones. Puede Download o Delete los archivos cargados.
-
En el panel de navegación izquierdo, vaya a . Seleccione el producto correspondiente para consultar los registros de carga de archivos del dispositivo.
En la pestaña Cloud-side Runtime Log, la lista de registros muestra Time, TraceID, Message Content, DeviceName, Business Type, Operation, Content y Status. Para las cargas de archivos del dispositivo, el tipo de negocio es Device File Upload y la operación es FileUploadFinished. El estado 200 indica éxito.
Siguientes pasos
Después de configurar el archivo de ejemplo, compílelo para crear el archivo ejecutable ./output/mqtt-upload-basic-demo. Compile and run the demo.
Para solucionar problemas con mensajes de error en los registros de ejecución, revise las descripciones de códigos de estado en aiot_mqtt_upload_api.h.