Configurar la función Advanced I/O
El directorio de la función Advanced I/O (functions/news_app_function) contiene los siguientes archivos:
- El archivo principal de la función main.py
- El archivo de configuración catalyst-config.json
- El archivo requirements.txt
Agregar código
Agregará código en el archivo main.py.
La función Advanced I/O obtiene el elemento de noticias de su tabla de origen en el Data Store y lo envía al componente client como una respuesta JSON.
Copie el código y péguelo en main.py en el directorio functions/news_app_function.
main.py
copy
import logging
from flask import Request, make_response, jsonify
import zcatalyst_sdk
def handler(request: Request):
#Inicializando el SDK de Catalyst
app = zcatalyst_sdk.initialize()
logger = logging.getLogger()
# API GET que obtiene las noticias de la tabla requerida
if request.path == "/fetchData":
table_name = request.args.get("tablename")
logger.info("Fetching news from datastore table - "+table_name)
zcql_instance = app.zcql()
# Consulta para obtener noticias de la tabla
query = "Select title,url from "+table_name
#Consulta la tabla del Catalyst Data Store y obtiene las noticias requeridas
zcql_result = zcql_instance.execute_query(query)
return jsonify({"content": zcql_result}), 200
else:
# Para ruta no definida se lanzará un error
response = make_response('Unknown path')
response.status_code = 400
return response
La función Advanced I/O está ahora configurada. Discutiremos la arquitectura de la aplicación después de configurar el client.
Última actualización 2026-03-20 21:51:56 +0530 IST