本文內容主要包含Pulsar的介紹和安裝、初步使用、應用、常見示例等。

一、 介紹和安裝

Pulsar是Python事件驅動併發框架；Pulsar具有高擴充套件性、高可用性的框架，它能夠基於事件驅動的開源實時分析平臺和處理框架，同時可以實時收集和處理使用者行為和業務事件。

官網地址為: https://pypi.org/project/pulsar/

安裝命令為:pip install pulsar

GitHub原始碼地址為: https://github.com/quantmind/pulsar

二、 初步使用

用pulsar

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流媒體