Uso de Amazon Kinesis con IBM App Connect Enterprise

Amazon Kinesis es un servicio web de Amazon (AWS) utilizado para procesar big data en tiempo real. Es un servicio gestionado, escalable y basado en la nube que puede utilizar para procesar grandes volúmenes de datos en streaming en tiempo real. IBM® App Connect Enterprise ofrece un nodo de solicitud de Amazon Kinesis, que puede utilizar para conectarse a Amazon Kinesis y enviar solicitudes sincrónicas con el fin de crear, recuperar, actualizar, eliminar o visualizar objetos como aplicaciones, flujos de datos, registros de flujos de datos, flujos de entrega, fragmentos y etiquetas.

1. En el kit de herramientas de « IBM App Connect Enterprise », crea un flujo que contenga un nodo «Amazon Kinesis Request ».
2. Seleccione el nodo Solicitud de Amazon Kinesis en el flujo para mostrar las propiedades del nodo en el editor.
3. En el separador Básico , pulse Iniciar descubrimiento de conector.
   Se visualiza un panel en el que se especifica el nombre del proyecto de política y los detalles de almacenamiento que se utilizarán durante el descubrimiento del conector.
4. Especifique los detalles del proyecto de política y almacenamiento que se utilizará durante el descubrimiento del conector:
   1. En el campo Proyecto de política , especifique el proyecto de política que se utiliza para almacenar las políticas que se crean durante el descubrimiento del conector.
      De forma alternativa, puede crear un nuevo proyecto de política pulsando Nuevo y especificando el nombre del nuevo proyecto de política. A continuación, pulse Finalizar.
   2. Especifique la caja fuerte que se utilizará durante el descubrimiento del conector. De forma predeterminada, las credenciales que se utilizan durante el descubrimiento del conector se almacenan en una caja fuerte de directorio externo, que es una caja fuerte de App Connect Enterprise que puede utilizar cualquier servidor de integración. De forma alternativa, puede almacenar las credenciales en una caja fuerte del servidor de integración, que se crea en el directorio de trabajo del servidor de integración y que sólo puede utilizar ese servidor de integración específico.
      Para especificar la caja fuerte que se utilizará para almacenar las credenciales, realice los pasos de la sección Utilización del asistente Descubrimiento de conector de uno de los temas siguientes:

      • Configuración de un almacén de directorios externo
      • Configuración de una caja fuerte del servidor de integración
   3. En el campo Clave de caja fuerte , especifique la clave de caja fuerte que se utiliza para acceder a las credenciales almacenadas en la caja fuerte. La clave de almacenamiento debe tener al menos 8 caracteres de longitud.
   4. Opcional: De forma predeterminada, la ubicación de caja fuerte especificada y la clave de caja fuerte se guardan como preferencias en el kit de herramientas para que los valores estén preestablecidos al iniciar el descubrimiento de conector. Si no desea que se guarden las preferencias, deseleccione Guardar en las preferencias de almacenamiento.
5. Pulse Iniciar descubrimiento para iniciar el asistente Descubrimiento de conector para el conector Amazon Kinesis .
   Se visualiza la ventana Descubrimiento de conector . Si hay disponibles conexiones (cuentas) de Amazon Kinesis existentes, se muestra una lista de dichas conexiones. Si no hay conexiones existentes, el estado del conector Amazon Kinesis se muestra como Not connected.
   • Si hay una o más conexiones (cuentas) de Amazon Kinesis disponibles, realice los pasos siguientes:
     1. Seleccione la conexión (cuenta) que desea utilizar pulsando en ella.
     2. Pulse el tipo de objeto necesario y, a continuación, seleccione la acción que desea realizar en el objeto. Por ejemplo, pulse Aplicaciones y, a continuación, Recuperar instantáneas de aplicación.
   • Si no hay conexiones (cuentas) existentes, realice los pasos siguientes:
     1. Pulse el tipo de objeto necesario y, a continuación, seleccione la acción que desea realizar en ese objeto. Por ejemplo, para recuperar instantáneas de aplicación de Amazon Kinesis, pulse Aplicaciones y, a continuación, Recuperar instantáneas de aplicación.
     2. Haga clic en Conectar para que aparezca un menú en el que debe seleccionar uno de los siguientes tipos de autorización:
        • Proporcionar credenciales para que App Connect las utilice (BÁSICO)
        • Proporcionar credenciales para que App Connect las utilice (OIDC BÁSICO)
     3. Si seleccionó Proporcionar credenciales para que App Connect las utilice (BÁSICO) como tipo de autorización, introduzca los siguientes detalles:
        • Clave de acceso secreta : La clave de acceso secreta de tu cuenta de Amazon Kinesis. Obtenga la clave de acceso secreta en la página Credenciales de seguridad de la consola de gestión AWS.
        • ID de clave de acceso : El ID de clave de acceso de tu cuenta de Amazon Kinesis. Obtenga el ID de la clave de acceso en la página Credenciales de seguridad de la consola de gestión AWS.
        • Región : La región de su instancia de Amazon Kinesis, por ejemplo, us-east-1. Puede encontrar el valor del parámetro Region al final de la URL cuando haya iniciado sesión en la consola de gestión AWS (por ejemplo, https://us-east-2.console.aws.amazon.com/console/home?region=us-east-2#).
          Consejo: Para obtener más información, consulte AWS service endpoints en la página de documentación AWS.
        • Nombre del proxy : Seleccione o especifique el nombre del proxy que desea App Connect utilizar para pasar las llamadas del conector. Este campo solo es obligatorio si las llamadas deben pasar por un proxy. Al utilizar el kit de herramientas « IBM App Connect Enterprise », el nombre del servidor proxy debe indicarse de la siguiente forma: {PolicyProjectName}:HTTPProxyPolicyName
     4. Si ha seleccionado Proporcionar credenciales para que App Connect las utilice (OIDC BÁSICO) como tipo de autorización, introduzca los siguientes detalles:
        • Región : La región de su instancia de Amazon Kinesis, por ejemplo, us-east-1. Puede encontrar el valor del parámetro Region al final de la URL cuando haya iniciado sesión en la consola de gestión AWS (por ejemplo, https://us-east-2.console.aws.amazon.com/console/home?region=us-east-2#).
          Consejo: Para obtener más información, consulte los puntos AWS finales del servicio en la página AWS de documentación.
        • ID de cliente : Especifica el identificador único asignado a una aplicación dentro de un sistema OpenID Connect (OIDC)
        • Secreto del cliente : Especifique el secreto del cliente que se utiliza para autenticar la aplicación cliente
        • Token de identificación : El token de seguridad en OpenID Connect (OIDC) que contiene afirmaciones sobre la autenticación de un usuario, como su identidad y la validez de la sesión, normalmente representado como un JSON Web Token (JWT)
        • Token de actualización : el token de actualización que se genera a partir del ID de cliente de la aplicación y el secreto del cliente
        • ARN de rol : El nombre de recurso de Amazon (ARN) que especifica un rol de IAM en AWS, definiendo los permisos concedidos a los usuarios autenticados a través de un proveedor de identidad compatible con OpenID Connect
        • Servidor OIDC URL : Especifique la dirección URL del servidor OpenID Connect (OIDC) o del proveedor de identidades que gestiona la autenticación y proporciona tokens a los clientes
        • Nombre del proxy : Seleccione o especifique el nombre del proxy que desea App Connect utilizar para pasar las llamadas del conector. Este campo solo es obligatorio si las llamadas deben pasar por un proxy. Al utilizar el kit de herramientas « IBM App Connect Enterprise », el nombre del servidor proxy debe indicarse de la siguiente forma: {PolicyProjectName}:HTTPProxyPolicyName
     5. Pulse Conectar.

     Para obtener más información sobre cómo identificar estos datos de conexión, consulta «Cómo utilizar IBM App Connect con Amazon Kinesis» en la documentación de Entrega Continua (CD) de IBM App Connect in containers.

6. Establezca las propiedades de conector necesarias en el asistente.
   Puede añadir condiciones para la recuperación de los objetos, como por ejemplo especificar el nombre de instantánea de una instantánea que pertenece a la cuenta de Amazon Kinesis . También puede establecer propiedades que especifiquen el número máximo de objetos a recuperar y la acción que se debe realizar si se supera ese límite.
7. Cuando haya terminado de especificar las propiedades en el asistente Descubrimiento de conector, pulse Guardar.
   Los valores de las propiedades que se configuran en el asistente se envían al nodo «Amazon Kinesis Request» del kit de herramientas de « IBM App Connect Enterprise ».
8. Cuando haya terminado de descubrir y guardado los valores de propiedad, salga del asistente de descubrimiento de conectores pulsando la X en la esquina superior derecha de la ventana.
9. Vuelve a editar el nodo «Amazon Kinesis Request» en el kit de herramientas « IBM App Connect Enterprise ».
   Las propiedades de conector que se han establecido en el asistente Descubrimiento de conector (en el paso 6) ahora están visibles en el nodo Solicitud de Amazon Kinesis . La pestaña Básico muestra los valores de las propiedades Acción y Objeto que ha establecido en el asistente. Por ejemplo, si seleccionó Aplicaciones > Recuperar instantáneas de aplicaciones en el asistente, las siguientes propiedades serán visibles en la pestaña Básico del nodo:

   • Acción - RETRIEVEALL
   • Objeto - applicationSnapshot

   Los valores de las propiedades Acción y Objeto se visualizan en formato de solo lectura. Si desea cambiar estos valores, puede hacerlo pulsando de nuevo Iniciar el descubrimiento del conector y estableciendo nuevos valores en el asistente de descubrimiento de conectores. Puede modificar otras propiedades (si las hay) pulsando Editar junto a la propiedad.

   La propiedad Nombre base de esquema especifica el nombre base de los archivos de esquema que describen el formato de los mensajes de solicitud y respuesta que se envían y reciben desde el conector Amazon Kinesis . El nombre base de esquema se establece automáticamente la primera vez que ejecuta el descubrimiento para el nodo, y se basa en el nombre de flujo y el nombre de nodo actuales. Si establece esta propiedad manualmente antes de ejecutar el descubrimiento por primera vez, se utilizará el valor que establezca. Si cambia el nombre de los esquemas después del descubrimiento, debe editar esta propiedad para que coincida con el nombre base del esquema que utilizan los esquemas renombrados en el proyecto. Si cambia esta propiedad después del descubrimiento, debe renombrar los nombres de esquema para que coincidan o volver a ejecutar el descubrimiento.

   En función de la acción seleccionada durante el descubrimiento, el asistente Descubrimiento de conector genera un esquema de solicitud y un esquema de respuesta o sólo un esquema de respuesta. Un esquema de solicitud sólo se genera si la acción y el objeto seleccionados requieren un mensaje de solicitud. El esquema de solicitud generado se utiliza para la validación del mensaje de solicitud. Si la acción era RETRIEVE o DELETE, el conector sólo devuelve el esquema de respuesta.

   Los archivos de esquema generados se añaden al proyecto y los puede utilizar un nodo Mapping para transformar datos de entrada o salida. El nombre de archivo completo del esquema se deriva del nombre base del esquema (por ejemplo, gen/MyMessageFlow.AmazonKinesis_Request), con el sufijo response.schema.json o request.schema.json. Puede abrir el esquema pulsando Abrir esquema de solicitud o Abrir esquema de respuesta.

10. Compruebe que los valores de propiedad en el nodo Amazon Kinesis Request son correctos y, a continuación, guarde el flujo de mensajes.
11. En la pestaña Conexión del nodo Solicitud de Amazon Kinesis , seleccione la política que contiene los detalles de la identidad de seguridad que se utilizará para la conexión. La política tiene un tipo de Amazon Kinesis.
    Para obtener más información, consulte la política de Amazon Kinesis.
12. Opcional: Establezca la propiedad Tiempo de espera en la pestaña Conexión para especificar el tiempo (en segundos) que el nodo espera a que Amazon Kinesis procese la operación.
13. La pestaña Filtro del nodo Amazon Kinesis Request contiene propiedades que controlan la forma en que el flujo de mensajes selecciona los datos. Los valores iniciales de estas propiedades se toman de los valores de propiedad que se han establecido para el conector Amazon Kinesis en el asistente Descubrimiento de conectores (tal como se describe en el paso 6). Si posteriormente vuelve al asistente Descubrimiento de conector y cambia los valores de las propiedades (añadiendo nuevas condiciones, por ejemplo), estas actualizaciones se reflejan en las propiedades establecidas en el nodo.

    Las propiedades Opciones de filtro controlan los objetos que deben utilizarse cuando se ejecuta el nodo Solicitud de Amazon Kinesis . Las propiedades Límite de filtro controlan el número máximo de elementos que se van a recuperar y la acción que se va a realizar si se supera el límite.

    Puede modificar los valores de estas propiedades en la pestaña Filtro del nodo, pulsando Editar junto al valor que desea modificar en la sección Opciones de filtro y cambiando los valores de propiedad que se han establecido en la sección Límite de filtro .

    Los valores de propiedad pueden ser valores de texto o expresiones ESQL o XPATH que se resuelven a partir del contenido del mensaje que se pasa al nodo Amazon Kinesis Request a medida que se ejecuta.

14. En la pestaña Solicitud , establezca la propiedad Ubicación de datos para especificar la ubicación en el árbol de mensajes de entrada que contiene los datos de objeto que se van a crear en Amazon Kinesis. Estos datos forman la solicitud que se envía desde el nodo Solicitud de Amazon Kinesis al sistema Amazon Kinesis .
15. En la pestaña Resultado , establezca la propiedad Ubicación de datos de salida para especificar la ubicación en el árbol de mensajes de salida que contendrá los datos del registro que se crea en Amazon Kinesis.
16. De forma predeterminada, los mensajes de solicitud se validan en el esquema de solicitud que se ha generado durante el descubrimiento del conector. Puede desactivar la validación de solicitud o cambiar los valores de validación utilizando las propiedades Validación del nodo Solicitud de Amazon Kinesis .
17. Guarde el flujo de mensajes.