我正在设置Zato作为我们的Web应用程序的ESB。 我仍然感觉到ESB是如何工作的,以及如何设置。
我一直在获取通过ESB公开的MySQL服务器。 有人可以让我开始?
我已经configuration了传出连接。 如何将该连接暴露给我的应用程序的其余部分?
一旦连接到SQL数据库,您可以通过self.outgoing.sql在Zato服务中引用它,如下面的示例中所示,它是从Zato文档中的 SQL使用示例复制而来的。
在这种情况下,所有的行都被简单地打印到服务器日志中,但是也可以将它们分配给self.response.payload,例如使用SimpleIO。
文档中还有其他用法示例。 不幸的是,我显然没有足够的信誉在ServerFault上作出超过2个链接的答案。
# stdlib from contextlib import closing # Zato from zato.server.service import Service class MyService(Service): def handle(self): # Always use templates and bind variables template = 'SELECT name FROM http_soap WHERE data_format=:data_format' parameters = {'data_format':'json'} with closing(self.outgoing.sql.get('my-conn').session()) as session: result = session.execute(template, parameters) for item in result: self.logger.info(item)