Bulk Write Rows

Catalyst enables you to perform bulk write jobs on a specific table present in the Data Store. The bulk write operation can fetch thousands of records from a CSV file uploaded in the File Store and insert them in a specific table.

The table is referred to by its unique table ID that is generated by Catalyst during creation. The column in which the write operation must be performed is referred to by its unique column ID.

Copy the SDK snippet below to perform a bulk write job on a particular table. To know more about the component instance datastore_service used below, please refer to this help section.

    

        
copy
        

            

        
    
    

         datastore_service = app.datastore()
bulk_write = datastore_service.table("Sample").bulk_write()
#Create bulk write job
bulk_write_job = bulk_write.create_job('6759000000165103', {
                    "find_by": 'EmpId',
                    "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)