Escritura masiva de filas

# Escritura masiva de filas
Catalyst te permite realizar trabajos de escritura masiva en una tabla específica presente en el {{%link href="/es/cloud-scale/help/data-store/introduction" %}}Data Store{{%/link%}}. La operación de escritura masiva puede obtener miles de registros de un archivo CSV cargado en {{%link href="/es/cloud-scale/help/stratus/introduction/" %}}Stratus{{%/link%}} e insertarlos en una tabla específica.
La tabla se referencia por su {{%link href="/es/cloud-scale/help/data-store/tables/" %}}{{%badge%}}table ID{{%/badge%}}{{%/link%}} único generado por Catalyst durante la creación. La columna en la que se debe realizar la operación de escritura se referencia por su {{%link href="/es/cloud-scale/help/data-store/columns/#column-characteristics" %}}ID de columna{{%/link%}} único.
{{%note%}}{{%bold%}}Note:{{%/bold%}} Para realizar una operación de escritura masiva, primero debes {{%link href="/es/cloud-scale/help/stratus/objects/upload-object/" %}}cargar{{%/link%}} los datos requeridos como un archivo CSV en Stratus.{{%/note%}}
<table class="content-table">
        <thead>
                <tr>
                        <th class="w20p">Nombre del parámetro</th>
      <th class="w20p">Tipo de dato</th>
      <th class="w60p">Definición</th>
                </tr>
        </thead>
        <tbody>
                <tr>
                        <td>{{%badge%}}tableID{{%/badge%}}</td>
      <td>String</td>
                        <td>Un parámetro {{%bold%}}obligatorio{{%/bold%}}. Contendrá el ID de la tabla en la que se deben escribir los datos.</td>
                </tr>
        <tr>
                        <td>{{%badge%}}find_by{{%/badge%}}</td>
      <td>String</td>
                        <td>Un parámetro {{%bold%}}obligatorio{{%/bold%}}. Contendrá el nombre de la columna en la que se deben escribir los datos.</td>
                </tr>
        <tr>
                        <td>{{%badge%}}fk_mapping{{%/badge%}}</td>
      <td>Array</td>
                        <td>Un parámetro {{%bold%}}obligatorio{{%/bold%}}. Contendrá los detalles de local_column y reference_column.</td>
                </tr>
        <tr>
                        <td>{{%badge%}}operation{{%/badge%}}</td>
      <td>String</td>
                        <td>Un parámetro {{%bold%}}obligatorio{{%/bold%}}. El valor de este parámetro debe ser insert.</td>
                </tr>
    <tr>
      <td>o{{%badge%}}bject_details{{%/badge%}}</td>
      <td>JSON Object</td>
      <td>
        <ul>
          <li>{{%badge%}}bucket_name{{%/badge%}}: El {{%link href="/es/cloud-scale/help/stratus/buckets/name-bucket/#ideal-practices-to-name-a-bucket" %}}nombre del bucket{{%/link%}}, donde se almacena el objeto.</li>
          <li>{{%badge%}}object_key{{%/badge%}}: Puede contener la {{%link href="/es/cloud-scale/help/stratus/objects/introduction/#path" %}}ruta{{%/link%}} o la {{%link href="/es/cloud-scale/help/stratus/objects/introduction/#object-url" %}}URL del objeto{{%/link%}} del objeto requerido.</li>
          <li>{{%badge%}}version_id{{%/badge%}}: Si el bucket tiene el {{%link href="/es/cloud-scale/help/stratus/stratus-config/general-settings/#versioning" %}}versionado{{%/link%}} habilitado, entonces el versionID específico del archivo se almacenará en este atributo.</li>
        </ul>
      </td>
    </tr>
        </tbody>
</table>
Copia el fragmento del SDK a continuación para realizar un trabajo de escritura masiva en una tabla en particular. Para conocer más sobre la instancia del componente {{%badge%}}datastore_service{{%/badge%}} utilizada a continuación, consulta {{%link href="/es/sdk/python/v1/cloud-scale/data-store/get-component-instance/" %}}esta sección de ayuda{{%/link%}}.
{{%code class="language-python" scroll="set-scroll" %}}datastore_service = app.datastore()
bulk_write = datastore_service.table("Sample").bulk_write()
object_details = {
  "bucket_name": "zcstratus12345",
  "object_key": "sample.csv",
  "version_id": "64832huidksnd83"
}
#create bulk write job
bulk_write_job = bulk_write.create_job(object_details, {
  "find_by": "S1",
  "fk_mapping": [
    {"local_column": "EmployeeID", "reference_column": "EmpId"},
    {"local_column": "DepartmentID", "reference_column": "DepId"}
  ],
  "operation": "insert"
})
#get bulk write status
status = bulk_write.get_status('6759000000167103')
#get bulk write result
result = bulk_write.get_result('6759000000167103')
{{%/code%}}
<br />
{{%note%}}{{%bold%}}Note:{{%/bold%}} Se pueden escribir un máximo de {{%bold%}}100,000 filas{{%/bold%}} a la vez.{{%/note%}}
{{%note%}}{{%bold%}}Info :{{%/bold%}} Consulta la {{%link href="/es/sdk/python/v1/sdk-scopes" %}}tabla de SDK Scopes{{%/link%}} para determinar el nivel de permiso requerido para realizar la operación anterior.{{%/note%}}

Catalyst te permite realizar trabajos de escritura masiva en una tabla específica presente en el Data Store. La operación de escritura masiva puede obtener miles de registros de un archivo CSV cargado en Stratus e insertarlos en una tabla específica. La tabla se referencia por su table ID único generado por Catalyst durante la creación. La columna en la que se debe realizar la operación de escritura se referencia por su ID de columna único.

Note: Para realizar una operación de escritura masiva, primero debes cargar los datos requeridos como un archivo CSV en Stratus.

Nombre del parámetro	Tipo de dato	Definición
tableID	String	Un parámetro obligatorio. Contendrá el ID de la tabla en la que se deben escribir los datos.
find_by	String	Un parámetro obligatorio. Contendrá el nombre de la columna en la que se deben escribir los datos.
fk_mapping	Array	Un parámetro obligatorio. Contendrá los detalles de local_column y reference_column.
operation	String	Un parámetro obligatorio. El valor de este parámetro debe ser insert.
object_details	JSON Object	bucket_name: El nombre del bucket, donde se almacena el objeto. object_key: Puede contener la ruta o la URL del objeto del objeto requerido. version_id: Si el bucket tiene el versionado habilitado, entonces el versionID específico del archivo se almacenará en este atributo.

Copia el fragmento del SDK a continuación para realizar un trabajo de escritura masiva en una tabla en particular. Para conocer más sobre la instancia del componente datastore_service utilizada a continuación, consulta esta sección de ayuda.

copy

         datastore_service = app.datastore()
bulk_write = datastore_service.table("Sample").bulk_write()
object_details = {
  "bucket_name": "zcstratus12345",
  "object_key": "sample.csv",
  "version_id": "64832huidksnd83"
}
#create bulk write job
bulk_write_job = bulk_write.create_job(object_details, {
  "find_by": "S1",
  "fk_mapping": [
    {"local_column": "EmployeeID", "reference_column": "EmpId"},
    {"local_column": "DepartmentID", "reference_column": "DepId"}
  ],
  "operation": "insert"
})
#get bulk write status
status = bulk_write.get_status('6759000000167103')
#get bulk write result
result = bulk_write.get_result('6759000000167103')

    

Note: Se pueden escribir un máximo de 100,000 filas a la vez.

Info : Consulta la tabla de SDK Scopes para determinar el nivel de permiso requerido para realizar la operación anterior.

Última actualización 2026-03-20 21:51:56 +0530 IST

Yes

Thank you for your feedback!

Send your feedback to us

Skip

Submit

Data Store Help SDK Scopes

SDK de Python

Operaciones del SDK

Escritura masiva de filas