概述
Zato是一个用Python编写的开源ESB和应用服务器。按照设计，它用于构建后端应用程序（即仅是API）和在SOA中整合系统。
查看Zato的项目文档点击这里，查看其GitHub页点击这里。
Zato的目标用户是使用Python或者Ruby和PHP等其它动态语言的开发人员，或者是那些考虑在工作中尝试动态语言的技术团队，后者或是因为看到动态语言在其它地方使用，或是因为愿意尝试用其中一种动态语言编写的非前端系统。
该平台是轻量级但完整的，它涵盖了架构师、程序员或者系统管理员的所有视角，对许多特性提供开箱即用的支持，包括HTTP、SON、SOAP、SQL、AMQP、JMS WebSphere MQ、ZeroMQ、Redis NoSQL、FTP、基于浏览器的GUI、CLI、API、安全、统计、作业调度、负载均衡和热部署。另外，它还提供了大量指南和参考样式方面的文档。
它的最初版本于2013年5月18日发布，最新的1.1版在6月初发布。
体系结构
Zato环境是一个或者多个集群的集合。每个集群由多个共享同一个SQL和Redis数据库的服务器构成。这些服务器的前端是集群专属的HA HTTP负载均衡器。
所有的服务器始终处于活动状态，并且总是运行同一组服务。为了实现active-standby设定，负载均衡器可以根据需要把任意服务器离线。
负载均衡器是一个嵌入式的HAProxy实例，管理员通过命令行或者通过GUI调用SSL XML-RPC对其进行远程控制，该过程可以用也可以不用客户端证书。用户可以给服务器赋予权重，以及使用HAProxy自身提供的其它功能，如连接ACL或速率限制。
服务器基于gunicorn/gevent项目构建。该项目是一个联合体，它使用libevent来选择每个平台支持的最佳异步事件通知库，如Linux平台上的epoll。
为了充分利用单台计算机能够提供的所有CPU，Zato按照设定好的数值预先生成一定数量的工作进程，每个进程使用选定的异步网络连接库来处理连接，所有进程监听相同的套接字。负载均衡器用于在不同的计算机之间分配负载及提供HA。
集群中的一台服务器担当启动AMQP/JMS WebSphere MQ/ZeroMQ资源调度器和连接器的角色。如果这台服务器意外宕机，那么始终处于活动状态的ping机制可以保证另外一台服务器接管这个角色。
应用程序可以使用多种协议进行集成，包括HTTP（对JSON/SOAP和纯XML有特殊支持）、FTP、AMQP、JMS WebSphere MQ（用于实现与现有的MQ Java应用程序之间的无缝互通性）、Redis和SQL。其中，HTTP协议是同步调用Zato服务的唯一方式。这种情况下，请求应用程序会进入阻塞状态等待响应。
程序员可以使用任何Python库。如果Zato自身尚未提供某个功能，也可以使用其它技术实现，如XML-RPC或者SMTP，该过程仅是一个导入Python内置包的问题而已。
集群管理使用基于浏览器的GUI和CLI。前者主要用于管理处于运行状态的集群，后者则用于在操作系统中安装Zato组件，如服务器。
集群配置信息存储在Redis和SQL操作型数据库中。Redis存储快速变化和频繁更新的数据，如统计信息或用户的运行时信息，而SQL ODB存储可以简单地映射成关系结构的数据。
虽然主要使用GUI进行环境配置，但也可以将集群的配置信息以JSON格式导出/导入，而且导出结果可以存储到一个外部的配置版本库，从而可以对其进行版本管理、标记或者版本间差异比较。
带有GUI的内置调度器可以用于一次性作业或者循环作业（也可以用Cron语法）。
服务器和服务只通过Redis和SQL ODB进行状态共享。没有自定义的协议或者数据格式用于保持服务器状态的一致性。
Zato使用超过160个自带的管理服务来进行自我管理，其中每一项都可以通过命令行或者在HTTP上以JSON/SOAP方式调用公共API获得。GUI和CLI工具本身都是这些服务的客户端。
Zato已经为Python应用程序创建了方便的客户端，所以用Python编写的应用程序在与Zato暴露的服务进行通信时还是只能使用Python对象。
服务
Zato服务是实现了单个特定方法的Python类。它可以接收输入和产生输出，也可以只接收输入或者只产生输出。
服务可以从GUI或者命令行以静态的或者热部署的方式安装。安装过程会自动将服务编译成字节码。
服务可以使用任何数据格式，但是Zato对JSON、SOAP和普通XML提供更多支持。如果使用了其中任何一种，序列化和反序列化都会在后台完成，开发人员只需通过点号就可以使用纯Python对象，而不必基于诸如XSD那样的模式创建Bean/模型/存根/类——尽管这意味着将没有代码完成。
同一服务可以在HTTP、AMQP、JMS WebSphere MQ、ZeroMQ和调度器上暴露，而不需要修改任何代码，也不需要重启服务器。特别地，只有在HTTP上暴露的服务可以进行同步调用。
SimpleIO（SIO）是一种声明式语法，用于表示简单的请求和响应。选用该语法，服务可以在不修改代码的情况下通过JSON或者XML/SOAP暴露。SIO不能处理复杂文档，它不接受任意嵌套的结构。任何结构的任何文档都可以用于Zato,只是有时不能用于SIO。
下面是一个基础服务的示例，该服务使用Yahoo YQL/JSON和Google’s XML API获取一家公司的市场资本总额。
该服务接收一个股票代码（例如GOOG或RHT），发出两个HTTP请求，然后清理响应并把它们组合成一个通用格式。根据请求格式的不同，组合结果以JSON或XML格式返回。
# anyjson
from anyjson import loads
# bunch
from bunch import bunchify
# decimal
from decimal import Decimal
# lxml
from lxml.objectify import fromstring
# Zato
from zato.server.service import Service
class GetMarketCap(Service):
""" 根据公司股票代码返回其市场资本总额，单位是10亿USD。
"""
class SimpleIO:
response_elem = 'market_cap'
input_required = ('symbol',)
output_required = ('provider', 'value')
def handle(self):
# . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
# Yahoo
# . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
# 通过名称获取到Y!的连接
yahoo = self.outgoing.plain_http.get('Yahoo! YQL')
# 创建用于YQL查询的URL参数。
q = 'select * from yahoo.finance.quotes where symbol="{}"'.format(
self.request.input.symbol)
url_params = {'q':q, 'format':'json',
'env':'http://datatables.org/alltables.env'}
# 调用 Y!，并从JSON响应创建一个bunch实例，这样就可以用点号
# 引用这些元素。
yahoo_response = bunchify(loads(yahoo.conn.get(self.cid, url_params).text))
# 清理Y!的响应——如果有业务响应，就去掉最后一个字符。
# 假设响应总是以10亿为单位。
if yahoo_response.query.results.quote:
value1 = yahoo_response.query.results.quote.MarketCapitalization
value1 = Decimal(value1[:-1]) if value1 else 'n/a'
else:
value1 = 'n/a'
# 一个新的响应条目会附加到条目列表，根据服务调用方式的不同，
#Zato会把它序列化为JSON或者XML。
item1 = {'provider':'Yahoo!', 'value': str(value1)}
self.response.payload.append(item1)
# . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
# Google
# . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .
# 通过名称获取到Google的连接
google = self.outgoing.plain_http.get('Google Finance')
# 创建用于调用Google的URL参数
url_params = {'stock':self.request.input.symbol}
# 调用 Google并从XML响应创建一个Objectify实例，这样就可以
# 用点号引用这些元素。
google_response = fromstring(google.conn.get(self.cid,
url_params).text)
# 清理Google的响应——如果有业务响应，就将百万转换成十亿。
if hasattr(google_response.finance, 'market_cap'):
value2 = Decimal(google_response.finance.market_cap.get('data')) / 1000
else:
value2 = 'n/a'
# 此外，将一个纯Python字典(hashmap)附加到响应对象，并由Zato
# 完成序列化
item2 = {'provider':'Google', 'value': str(value2)}
self.response.payload.append(item2)
这是一个非常简单的集成示例，而并不是所有的场景都允许使用SIO，但是不管服务多复杂，有一点需要强调，就是不应该回避使用Python进行编码。除了可执行外，从许多方面看来，它都非常像伪代码——这里有更多的使用示例可以说明这一点。
以上是小编为您精心准备的的内容，在的博客、问答、公众号、人物、课程等栏目也有的相关内容，欢迎继续使用右上角搜索按钮进行搜索python
， zeromq
， 服务器
， zeromq丢消息
， redis 3.0集群
， 集群
， lxml
， 服务
， python 服务端
， amqp
， gunicorn
， 一个
， python安装requests库
或者
，以便于您获取更多的相关知识。