本文內容主要包含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流媒體