Python之Pulsar框架使用

Posted 2021-01-24 挑战者V

本文内容主要包含Pulsar的介绍和安装、初步使用、应用、常见示例等。

一、 介绍和安装

Pulsar是Python事件驱动并发框架；Pulsar具有高扩展性、高可用性的框架，它能够基于事件驱动的开源实时分析平台和处理框架，同时可以实时收集和处理用户行为和业务事件。

 

官网地址为: https://pypi.org/project/pulsar/

 

安装命令为:pip install pulsar

 

GitHub源码地址为: https://github.com/quantmind/pulsar

 

 

二、 初步使用

用pulsar编写的Web服务器示例，每个请求都响应“Hello World！”：

from pulsar.apps import wsgi

def hello(environ, start_response):
    data = b\'Hello World!\\n\'
    response_headers = [
        (\'Content-type\',\'text/plain\'),
        (\'Content-Length\', str(len(data)))
    ]
    start_response(\'200 OK\', response_headers)
    return [data]


if __name__ == \'__main__\':
wsgi.WSGIServer(callable=hello).start()

 

运行效果如图:

 

三、应用

Pulsar设计允许以优雅和有效的方式实现许多不同的异步应用程序。开箱即用，随附以下内容：

• 套接字服务器
• 异步WSGI服务器
• HttpClient的
• JSON-RPC
• Web套接字
• 异步测试套件
• 数据存储（使用异步Redis客户端）
• 任务队列使用者
• 异步botocore
• django整合

 

四、常见示例

查看各种工作应用程序的示例目录。这包括：

• 你好，世界！wsgi的例子(前面的入门示例)
• 一个Httpbin WSGI应用程序
• HTTP代理服务器
• JSON-RPC计算器服务器
• Websocket随机图。
• Websocket聊天室。
• 在哲学家就餐问题。
• Twitter流媒体