import logging import os from re import A import sys import asyncio from fastapi import FastAPI, WebSocket from fastapi.responses import HTMLResponse import uvicorn from processcube_client.external_task import ExternalTaskClient logger = logging.getLogger(__name__) PORT = 8889 app = FastAPI() HTML = f""" Chat

WebSocket Chat

Call the api

/api

Execute an bpmn diagram

Deploy bpmn_models/hello_external_task.bpmn
Start a process instance
Wait for the external task to be completed

""" class WithTaskHandler(object): def __call__(self, payload, task): logger.info(f"WithTaskHandler.__call__: payload {payload} for task {task}") return {'some': 'result'} class WithAsyncTaskHandler(object): async def __call__(self, payload, task): logger.info(f"WithTaskHandler.__call__: payload {payload} for task {task}") return {'some': 'result'} async def _handler_with_task(payload, task): logger.info(f"_handler_with_task: payload {payload} for task {task}") return {'some': 'result'} def _handler(payload): logger.info(f"_handler: payload {payload}") return {'some': 'result'} @app.get("/", response_class=HTMLResponse) async def index(): return HTML @app.get("/api") async def root(): return {"message": "Hello World"} @app.websocket("/ws") async def websocket_endpoint(websocket: WebSocket): await websocket.accept() while True: data = await websocket.receive_text() await websocket.send_text(f"Message text was: {data}") @app.on_event("shutdown") def shutdown_event(): print("shutdown event") @app.on_event("startup") def start_external_task(): atlas_engine_stable = 'http://localhost:56000' atlas_engine_insiders = 'http://localhost:56100' current_atlas_engine = atlas_engine_insiders loop = asyncio.get_running_loop() external_task_client = ExternalTaskClient(current_atlas_engine, loop=loop) #handler = WithTaskHandler() #external_task_client.subscribe_to_external_task_for_topic("SampleExternalTask", handler, loop=loop) async_handler = WithAsyncTaskHandler() external_task_client.subscribe_to_external_task_for_topic("SampleExternalTask", async_handler) #external_task_client.subscribe_to_external_task_for_topic("SampleExternalTask", _handler_with_task, loop=loop) #external_task_client.subscribe_to_external_task_for_topic("SampleExternalTask", _handler, loop=loop) external_task_client.start(run_forever=False) def main(): print("--------------") format_template = '%(asctime)s - %(name)s - %(levelname)s - %(message)s' level = logging.INFO #logging.DEBUG | logging.ÍNFO logging.basicConfig(level=level, format=format_template) uvicorn.run("external_task_with_server:app", port=PORT, reload=False, loop='asyncio') if __name__ == '__main__': main()

Lädt...