Bulk Producer
El Bulk Producer es responsable de suscribirse al flujo de componentes de bulk proporcionado por el Joiner y escribir cada uno en un File Writer soportado, lo que resulta en la producción de un archivo de bulk.
El archivo de bulk se emitirá en una ubicación especificada en las configuraciones del bulk, donde cada entrada de configuración podría tener su propia ubicación de salida.
La configuración relevante se describe a continuación:
| Config | Type | Default | Comment |
|---|---|---|---|
|
String |
|
Propiedad que define la ubicación a la que se transmitirá el archivo de bulk de salida. Valores válidos: |
|
String |
N/A |
Propiedad que define el directorio o bucket de S3 al que se transmitirán los archivos en el sistema de archivos especificado arriba. |
Ejemplo:
ipf.bulker {
output.file-system = "local"
configurations = [
{
name = "pain.001.001.09"
file-name-prefix = "bulk-"
file-path = "/tmp/bulks"
component-hierarchy {
component-parser-name = "xml"
marker = "Document"
children = [
{
marker = "CstmrCdtTrfInitn.PmtInf"
children = [
{
before-elements = ["SplmtryData"]
marker = "CdtTrfTxInf"
}
]
}
]
}
auto-close-triggers = ["customAutoCloseTrigger"]
maximum-component-size = 50
scheduled-auto-close = {
auto-close-by-age = 30s
schedule-at = "*/10 * * ? * *"
}
finalise-on-auto-close = true
}
]
}Reintentos
Si hay un fallo del sistema mientras se está produciendo un archivo de bulk, entonces al reiniciar el proceso de producción del archivo se reintentará.
Si en algún momento durante el proceso de producción del archivo de bulk se encuentra una excepción, se generará un evento del sistema que permitirá que tenga lugar un proceso de intervención manual. En este escenario, se debe eliminar manualmente el archivo de bulk con problemas detallado en el evento antes de intentar finalizar el bulk nuevamente.