Ejecutar el ejemplo de depósito de datos
Puede ejecutar el
ejemplo de depósito de datos para realizar el siguiente proceso:
- Leer un mensaje de WebSphere MQ con una carga útil en formato XML.
- Convertir toda la carga útil del mensaje entrante en un BLOB e insertarlo en una base de datos.
- Dar formato a un mensaje de confirmación.
- Grabar un mensaje de confirmación de WebSphere MQ para confirmar la inserción del mensaje en la base de datos.
- Comprobar el número de registros que se han insertado en la base de datos.
La forma de visualizar el contenido de la base de datos del ejemplo depende de el producto de base de datos que se
haya instalado.
Para bases de datos DB2 utilice las herramientas proporcionadas por DB2; por ejemplo, el Centro de control de DB2. Si
no ha instalado un producto de base de datos, los ejemplos utilizarán la base de datos Apache Derby. Las instrucciones
para la visualización de los datos en una base de datos Derby, consulte
Ver el contenido de una base
de datos Derby.
Para ejecutar el flujo de mensajes WarehouseData:
- Asegúrese de que el conjunto de mensajes y los flujos de mensajes de ejemplo se hayan desplegado.
Al importar el ejemplo, es posible que se hayan producido varios
avisos relacionados con los archivos
.msgflow. Estos avisos están asociados
a bases de datos y no afectarán la ejecución del ejemplo.
- Efectúe una doble pulsación en Datawarehouse_input_message.enqueue, en
el proyecto de flujo de mensajes al que se haya importado el ejemplo.
- Revise los valores del Nombre del gestor de colas y del Nombre de cola en el
separador General. Cuando se utiliza el nombre del gestor de colas por omisión y la configuración del
intermediario de mensajes no es necesario cambiar los valores pero debe asegurarse que
el campo Puerto contiene el valor 2414.
- >Pulse en Grabar en cola para colocar un mensaje de WebSphere MQ en la cola de
entrada del flujo de mensajes WarehouseData.
- Inicie una instancia de la aplicación Dequeue:
- En la barra de herramientas del área de trabajo, pulse en la flecha del icono Obtener un mensaje de una cola
.
- En el menú desplegable, pulse en Obtener mensaje para abrir la ventana
Extraer mensaje de cola.
- Escriba los nombres del gestor de colas y de la cola que desee. Use valores
de WBRK6_DEFAULT_QUEUE_MANAGER como nombre del gestor de
colas y DATAWAREHOUSE_OUT_Q como nombre de la cola para
trabajar con la configuración por omisión.
- Pulse en Leer de cola para leer un mensaje de la cola.
- Después de cerrar la ventana, la siguiente vez que pulse en la flecha del
icono Obtener un mensaje de una cola
,
verá la configuración de extraer de la cola que creó anteriormente listada en el menú desplegable. Pulse en ese archivo en el menú (o si es el número 1 del menú, pulse únicamente en el icono propiamente dicho) para
obtener un mensaje de la cola.
- Opcional: mientras la ventana Extraer mensaje de cola esta abierta, podrá
guardar un mensaje de lectura en un archivo del proyecto de flujos de mensajes para guardarlo para más adelante. Pulse en Guardar como y, en la ventana Guardar mensaje como, seleccione
el proyecto de flujo y entre un nombre para el archivo.
- Vea el contenido del mensaje que se ha recuperado y compruebe que se haya almacenado un mensaje en la base de datos. Anote la hora en que se almacenó el mensaje en la base de datos. Necesitará usar esa hora cuando ejecute el flujo de mensajes
VerifyDatabaseContents.
- Inicie otra instancia de la aplicación de extraer de la cola (mismo proceso que para el anterior paso 5).
- Use valores de WBRK6_DEFAULT_QUEUE_MANAGER
como nombre del gestor de colas y DATAWAREHOUSE_FAILURE_Q
como nombre del la cola para trabajar con la configuración por omisión.
- Pulse en Leer de cola para leer un mensaje de la cola.
- Compruebe que no se haya recuperado ningún mensaje. Esta instancia de la aplicación de extraer de la cola
lee todos los mensajes de error que haya de la inserción en la base de datos. No debería haber ninguno.
Al llegar a este punto, el flujo de mensajes WarehouseData se habrá ejecutado correctamente.
El siguiente paso es ejecutar el flujo de mensajes VerifyDatabaseContents para contar los registros de la base de datos. Para ello:
- Efectúe una doble pulsación en Datawarehouse_verify_contents_input_message.enqueue
en proyecto de flujos de mensajes al que se importó el ejemplo.
- Revise los valores del Nombre del gestor de colas y del Nombre de cola en el separador General. Cuando se
utiliza el nombre del gestor de colas por omisión y la configuración del intermediario de mensajes no es necesario
cambiar los valores.
- En la parte de datos del mensaje de la ventana especifique valores para la fecha y hora de inicio y final de la consulta.
Esos valores han de pertenecer a cualquiera de las horas en las que tuvo lugar la inserción de la base de datos
cuando ejecutó el flujo de mensajes WarehouseData.
Se informa de la hora de la inserción en el mensaje que se graba en DATAWAREHOUSE_OUT_Q.
- >Pulse en Grabar en cola para colocar un mensaje de
WebSphere MQ en la cola de entrada del flujo de mensajes VerifyDatabaseContents.
- Inicie otra instancia de la aplicación Dequeue (extraer de la cola):
- Use valores de WBRK6_DEFAULT_QUEUE_MANAGER
para el nombre del gestor de colas y DATAWAREHOUSE_VERIFY_CONTENTS_OUT_Q
como nombre de cola para trabajar con la configuración por omisión.
- Pulse en Leer de cola para leer un mensaje de la cola.
- Compruebe que la cuenta de registros de la base de datos es uno.
- Realice varias peticiones de archivado más utilizando el flujo de mensajes WarehouseData
y compruebe si la cuenta de
registros sigue aumentando a la misma velocidad utilizando el flujo de mensajes VerifyDatabaseContents para obtener la
cuenta del número de registros en la base de datos Dependiendo del valor
de la hora de finalización que haya especificado inicialmente, puede que tenga que actualizar el valor en el archivo
Datawarehouse_verify_contents_input_message.enqueue
Cuando haya visto que la petición de archivado ha terminado correctamente y que la cuenta de registros de la base de
datos corresponde al número de archivos emitidos, habrá ejecutado correctamente el ejemplo de depósito de datos.
Volver a la Página de presentación de ejemplos