Enviando archivo Notifications

El Debulker puede aprender que hay un archivo listo para su procesamiento a través de una notificación, una API se proporciona lo que es esencialmente un receive connector. El Debulker viene con un Kafka implementación de esto receive connector.

Esto significa que algo (script/aplicación/flujo) necesita enviar un Kafka evento a un tema específico, comunicando así que un nuevo archivo está listo para su procesamiento.

Configuración

El tema predeterminado es FILE_NOTIFICATION_REQUEST, pero puede ser anulado, consulte el página de características aquí.

Formato de Notificación

La notificación tiene varias propiedades que deben ser proporcionadas:

  • configName - nombre de la configuración que será utilizada por el debulker para descomponer el archivo en componentes.

  • bulkId - un Id globalmente único para correlacionar los componentes producidos por el deshidratador.

  • fileProvider - nombre del proveedor que se utilizará para recuperar el archivo en bloque para su procesamiento.

  • filePath - ruta al archivo.

Ejemplo de mensaje de notificación de archivo:

{
  "configName": "pain.001.001.09",
  "bulkId": "pain.001.12345",
  "fileProvider": "local",
  "filePath": "/tmp/bulk_files",
  "fileName": "pain_001_test.xml"
}