IoT Platform:Agregar un origen de datos de servicio en la nube

Información de facturación

La sincronización de datos desde un origen de datos de servicio en la nube hacia IoT Platform genera costos por unidades de procesamiento de datos (DPU).

Límites

• Actualmente, solo es posible sincronizar archivos de un bucket de OSS con DataService Studio en IoT Platform.

• Cada archivo en un bucket de OSS no debe superar 1 GB. Los archivos diarios deben organizarse en carpetas nombradas por fecha.

  Formatos de fecha compatibles:

  • Día: YYYYMMDD, por ejemplo: 20230302.

  • Hora: YYYYMMDDHH, por ejemplo 2023030213.

Crear un origen de datos de servicio en la nube

1. En la consola de IoT Platform, vaya a la página de Overview y haga clic en el ID o alias de la instancia Enterprise Edition de destino.

2. En la barra de navegación izquierda, seleccione DataService Studio > Data Ingestion y haga clic en la pestaña Cloud Service.

3. En la pestaña Cloud Service, haga clic en Create Cloud Service Data Source.

4. En el panel derecho, siga estos pasos para completar la configuración del origen de datos de servicio en la nube.

Información básica

1. En la página del asistente Basic Information, configure los siguientes parámetros.

   Parámetro	Descripción
   Name	Nombre del origen de datos de servicio en la nube. Puede contener caracteres chinos, letras, dígitos, puntos (.), guiones bajos (_) y paréntesis (). Longitud máxima: 32 caracteres.
   Description	Descripción del origen de datos de servicio en la nube.
   Cloud Service Type	Actualmente, solo se admite OSS.
   Bucket	Seleccione un bucket de OSS. Para obtener instrucciones sobre cómo crear un bucket en OSS, consulte Create a bucket. Importante Antes de configurar el bucket, haga clic en Create junto al aviso de rol no creado para generar un rol vinculado al servicio. Este rol autoriza a DataService Studio a acceder y sincronizar datos desde su bucket de OSS. Para obtener más información sobre los roles vinculados al servicio, consulte Service-linked role for cloud product data ingestion.
   Parent Directory	Directorio principal del archivo en el bucket. Para obtener más información sobre la gestión de directorios de archivos, consulte Manage directories.

2. Haga clic en Next.

Mapeo de campos

1. En la página del asistente Field Mapping, configure el formato de datos del origen.

   Parámetro	Descripción
   Data Format	Seleccione una de las siguientes opciones: JSON: Formato JSON. ProtoBuf: Formato ProtoBuf. CSV: Formato CSV. Customize: Un script personalizado para analizar sintácticamente el formato de datos.
   Row Delimiter	Seleccione una de las siguientes opciones: System Default Delimiter, Comma, Vertical Line, Space, Tab Character o Customize. Si selecciona System Default Delimiter, se utiliza automáticamente el delimitador del sistema. Si selecciona Customize, introduzca un carácter visible. Nota Cuando Data Format es JSON, Row Delimiter no puede ser Comma. Para Data Format establecido en ProtoBuf, se utiliza un salto de línea específico del protocolo. Al escribir datos en un archivo, use writeDelimitedTo (Java) o delimited_message_util.h (C++). No se admiten delimitadores de fila personalizados. Cuando Data Format es CSV, Row Delimiter tiene como valor predeterminado System Default Delimiter y no se puede modificar.
   Column Delimiter	Este parámetro solo está disponible cuando Data Format está configurado como CSV. Opciones: Comma, Vertical Line, Space, Tab Character o Customize.

2. Haga clic en Configure en el cuadro de diálogo Field Mapping para configurar el mapeo de campos del origen de datos.

   1. Configure datos de muestra para el análisis sintáctico del formato según el formato de datos seleccionado.

      Formato de datos	Operación
      JSON	En el cuadro Sample Data, introduzca datos de muestra en formato JSON. Solo se admiten entradas de datos de una sola línea. Importante No se admiten entradas de datos en formato de matriz.
      ProtoBuf	Cargue un archivo .desc haciendo clic en Upload .desc File para analizar sintácticamente los datos en formato ProtoBuf. Para obtener instrucciones sobre cómo generar un archivo .desc, consulte Appendix: Generating .desc Files. Seleccione el tipo de mensaje y cargue datos de muestra haciendo clic en Upload Binary Data File. Importante No se admiten entradas de datos en formato de matriz.
      CSV	Introduzca los datos de muestra directamente en el cuadro Sample Data. Los datos de muestra deben incluir nombres de columna y contener solo una línea de datos. Por ejemplo, con Column Delimiter establecido en Comma: productKey,deviceName,time,temperature,humidity g9rp0*****,device1,20230102,23,30
      Customize	Seleccione un lenguaje de script e introdúzcalo en el cuadro Edit Script. El lenguaje de script compatible es Javascript (ecmascript 5), con el nombre de función definido como parse_line. Para plantillas y ejemplos de scripts, consulte Write custom scripts. En la pestaña Analog Input, introduzca datos de reporte del dispositivo analógico según el delimitador de fila.

   2. Valide el análisis sintáctico de los datos:

      • Si Data Format es JSON, ProtoBuf o CSV, haga clic en Validate Parsing:

        • Si el análisis sintáctico es exitoso, la información de los campos analizados se muestra bajo Data Storage Type.

        • Si falla, ajuste los datos de muestra según las indicaciones e inténtelo de nuevo.

      • Si Data Format es Customize, haga clic en Execute:

        • Si la ejecución es exitosa, los datos analizados aparecen en la pestaña Execution Result.

        • Si falla, revise el script según los comentarios recibidos e inténtelo nuevamente.

   3. En la lista de campos analizados, asigne el Field Display Name y designe una Primary Key.

      El Field Display Name puede contener caracteres chinos, letras, dígitos, guiones bajos (_), guiones (-) y paréntesis (). Longitud máxima: 30 caracteres.

   4. Haga clic en Confirm.

3. Haga clic en Next.

Ciclo de sincronización

1. Seleccione la frecuencia para el Synchronization Cycle: Hour o Day.

2. Elija la Earliest Synchronization Time.

3. Haga clic en Finish.

Después de crear un origen de datos de servicio en la nube:

• En la pestaña Data Ingestion > Cloud Service, aparece listada la nueva tarea de sincronización del origen de datos. El Synchronization Status es Stopped de forma predeterminada. Debe habilitar la sincronización manualmente. Para obtener más información, consulte Enable Cloud Service Data Source Synchronization.

• En la pestaña Data Storage > Cold Data Storage > Custom Storage Table, se crea una tabla de almacenamiento que utiliza el nombre del origen de datos de servicio en la nube como nombre de tabla.

Habilitar la sincronización del origen de datos de servicio en la nube

Para habilitar la sincronización de datos y permitir que los datos del servicio en la nube se ingieran en DataService Studio:

1. Vaya a la pestaña Cloud Service y localice la tarea de sincronización del origen de datos que desea habilitar.

2. Active el interruptor de Synchronization Status en la columna Stopped correspondiente .

Una vez habilitada la sincronización, el Synchronization Status de la tarea cambia a Synchronizing. El sistema sincroniza los datos del servicio en la nube con la tabla de almacenamiento personalizada en DataService Studio según el ciclo configurado.

Operaciones opcionales

Editar la configuración del origen de datos de servicio en la nube

1. En la pestaña Cloud Service, localice el origen de datos de servicio en la nube que desea editar.

2. Haga clic en el botón Edit en la columna Operation correspondiente.

3. En el panel Edit Cloud Service Data Source, modifique las configuraciones según sea necesario.

Eliminar origen de datos de servicio en la nube

Solo puede eliminar un origen de datos de servicio en la nube cuando su estado de sincronización está detenido.

1. Vaya a la pestaña Cloud Service y localice el origen de datos de servicio en la nube que desea eliminar.

2. Haga clic en el botón Delete en la columna Operation correspondiente.

3. Haga clic en Confirm para confirmar la eliminación.

Siguientes pasos

Para gestionar tareas de sincronización y tablas de almacenamiento de datos, consulte Manage data synchronization tasks and storage tables.