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 |
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 |
|
AccessKey Secret |
Corresponde a la |
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: |
Sí |
Ninguna |
|
object |
Ruta del archivo. Admite el comodín asterisco ( Por ejemplo, para sincronizar |
Sí |
Ninguna |
|
column |
Lista de campos por leer. Para leer todas las columnas como STRING, utilice la siguiente configuración.
Para especificar columnas individuales:
Nota
Cada definición de column debe incluir el parámetro |
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: |
Sí |
, |
|
lineDelimiter |
Delimitador de línea. Este parámetro solo es válido cuando |
No |
Ninguna |
|
compress |
Tipo de compresión. De forma predeterminada, no se aplica ninguna compresión. Tipos compatibles: |
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:
|
No |
Ninguna |
|
skipHeader |
Para archivos CSV, especifica si se debe omitir la primera línea (la fila de encabezado).
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:
Detalles del formato de
Ejemplo:
|
No |
Ninguna |
|
csvReaderConfig |
Parámetros avanzados para el lector CSV. Si no se especifican, se utilizan los valores predeterminados. |
No |
Ninguna |