Todos los productos
Search
Centro de documentos

DataWorks:Origen de datos COS

Última actualización: Sep 04, 2026

El conector de origen de datos COS lee archivos de Tencent Cloud Object Storage (COS), analiza su contenido y sincroniza los datos con cualquier destino compatible en DataWorks.

Tipos de datos

Los orígenes de datos COS admiten los siguientes tipos de datos.

Tipo

Descripción

STRING

Texto.

LONG

Entero.

BYTES

Matriz de bytes. El contenido de texto se convierte en una matriz de bytes con codificación UTF-8.

BOOL

Booleano.

DOUBLE

Número de punto flotante.

DATE

Tipo de fecha y hora. Los formatos compatibles incluyen YYYY-MM-dd HH:mm:ss y yyyy-MM-ddHH:mm:ss.

Cree un origen de datos

Antes de desarrollar una tarea de sincronización de datos, cree un origen de datos en DataWorks. Para más información sobre el procedimiento, consulte Data Source Management. Las descripciones emergentes en la interfaz de configuración proporcionan información detallada sobre cada parámetro.

Parámetros clave:

Parámetro

Descripción

Data Source Name

Nombre personalizado para el origen de datos, único dentro del espacio de trabajo. El nombre puede contener letras, números y guiones bajos (_), pero no puede comenzar con un número ni con un guion bajo.

Region

Región donde se encuentra el bucket. Especifique el ID de región. Para obtener más información, consulte Regiones y dominios de acceso.

Bucket

Nombre del bucket de COS.

Endpoint

Endpoint de COS. Para obtener más información, consulte Regiones y dominios de acceso.

AccessKey ID

Corresponde al SecretId en la plataforma de Tencent Cloud. Puede obtenerlo desde la página API Key Management en la consola.

AccessKey Secret

Corresponde a la SecretKey en la plataforma de Tencent Cloud. Puede obtenerla desde la página API Key Management en la consola.

Desarrollar una tarea de sincronización de datos

Para consultar el procedimiento general y los detalles de configuración, revise las siguientes secciones.

Tarea de sincronización sin conexión de tabla única

Para consultar el procedimiento, véase Configure in codeless UI y Configure in code editor. Para obtener una lista completa de parámetros y un ejemplo de script para el editor de código, consulte el apéndice.

Apéndice: Ejemplo de script y parámetros

Script de tarea de sincronización sin conexión

Al utilizar el editor de código para configurar una tarea de sincronización sin conexión, formatee los parámetros del script según sea necesario. Para obtener más información, consulte Configure in code editor. Las siguientes secciones describen los parámetros del lector para este origen de datos.

Ejemplo de script del lector

{
  "type": "job",
  "version": "2.0",
  "steps": [
    {
      "stepType": "cos",
      "parameter": {
        "datasource": "",
        "object": ["f/z/1.csv"],
        "fileFormat": "csv",
        "encoding": "utf8/gbk/...",
        "fieldDelimiter": ",",
        "useMultiCharDelimiter": true,
        "lineDelimiter": "\n",
        "skipHeader": true,
        "compress": "zip/gzip",
        "column": [
          {
            "index": 0,
            "type": "long"
          },
          {
            "index": 1,
            "type": "boolean"
          },
          {
            "index": 2,
            "type": "double"
          },
          {
            "index": 3,
            "type": "string"
          },
          {
            "index": 4,
            "type": "date"
          }
        ]
      },
      "name": "Reader",
      "category": "reader"
    },
    {
      "stepType": "stream",
      "parameter": {},
      "name": "Writer",
      "category": "writer"
    }
  ],
  "setting": {
    "errorLimit": {
      "record": "0"
    },
    "speed": {
      "concurrent": 1
    }
  },
  "order": {
    "hops": [
      {
        "from": "Reader",
        "to": "Writer"
      }
    ]
  }
}

Parámetros del script del lector

Parámetro

Descripción

Obligatorio

Predeterminado

datasource

Nombre del origen de datos. Este valor debe coincidir con el nombre del origen de datos que creó en DataWorks.

Sí

Ninguna

fileFormat

Formato del archivo de origen. Formatos compatibles: csv, text, parquet y orc.

Sí

Ninguna

object

Ruta del archivo. Admite el comodín asterisco (*) y matrices de rutas.

Por ejemplo, para sincronizar a/b/1.csv y a/b/2.csv, establezca este parámetro en a/b/*.csv.

Sí

Ninguna

column

Lista de campos por leer. type especifica el tipo de dato de origen, index indica el número de columna basado en cero en el archivo de origen y value define una constante. El uso de value genera una columna con la constante especificada en lugar de leerla del archivo de origen.

Para leer todas las columnas como STRING, utilice la siguiente configuración.

"column": ["*"]

Para especificar columnas individuales:

"column":    
    {       
        "type": "long",       
        "index": 0 // Obtener un campo LONG de la primera columna del archivo de texto COS.
    },    
    {       
        "type": "string",       
        "value": "alibaba" // Generar un campo STRING con el valor constante "alibaba".
}
Nota

Cada definición de column debe incluir el parámetro type y el parámetro index o value.

Sí

Todas las columnas se leen como tipo STRING.

fieldDelimiter

Separador de campos utilizado al leer datos. Debe especificar un separador; si se omite, se usa una coma (,) de forma predeterminada y se rellena automáticamente en la interfaz. Para caracteres invisibles, introduzca la codificación Unicode, por ejemplo: \u001b o \u007c.

Sí

,

lineDelimiter

Delimitador de línea. Este parámetro solo es válido cuando fileFormat se establece en text.

No

Ninguna

compress

Tipo de compresión. De forma predeterminada, no se aplica ninguna compresión. Tipos compatibles: gzip, bzip2 y zip.

No

Sin comprimir

encoding

Codificación de caracteres de los archivos de origen.

No

utf-8

nullFormat

Cadena en el archivo de origen que se interpretará como valor nulo. Por ejemplo:

  • Si establece nullFormat en "null", la cadena "null" en los datos de origen se sincroniza en la tabla de destino como un valor NULL.

  • Establezca nullFormat en "\u0001", que es un carácter invisible. Si un campo de origen es la cadena "\u0001", se trata como un campo nulo y se escribe en la tabla de destino.

  • Si no especifica nullFormat, los datos de origen se escriben en el destino tal cual, sin conversión.

No

Ninguna

skipHeader

Para archivos CSV, especifica si se debe omitir la primera línea (la fila de encabezado).

  • true: Se omite la primera línea del archivo.

  • false: La primera línea del archivo se lee como un registro de datos.

Nota

El parámetro skipHeader no es compatible con archivos comprimidos.

No

false

parquetSchema

Esquema para leer archivos Parquet. Obligatorio solo cuando fileFormat se establece en parquet. El formato general es:

message MessageTypeName {
  required|optional DataType ColumnName;
  required|optional DataType ColumnName;
  ...;
}

Detalles del formato de parquetSchema:

  • MessageTypeName: Nombre del tipo de mensaje.

  • required u optional: required indica un campo no nulo, mientras que optional permite valores nulos. Se recomienda establecer todos los campos como optional.

  • DataType: Los tipos de datos Parquet compatibles incluyen BOOLEAN, Int32, Int64, Int96, FLOAT, DOUBLE, BINARY (utilizar para tipos de cadena) y fixed_len_byte_array. Cada definición de campo debe terminar con punto y coma (;), incluido el último.

Ejemplo:

{"parquetSchema": "message UserProfile 
{ optional int32 minute_id; 
  optional int32 dsp_id; 
  optional int32 adx_pid; 
  optional int64 req; 
  optional int64 res; 
  optional int64 suc; 
  optional int64 imp; 
  optional double revenue; }"
}

No

Ninguna

csvReaderConfig

Parámetros avanzados para el lector CSV. Si no se especifican, se utilizan los valores predeterminados.

No

Ninguna