ทดสอบ
Project description
MDA streaming library
สวัสดีนี่กิตเอง
Install
pip install mdalib
require: kafka-python, msgpack, requests
Method
import mdalib
def test(topic, val):
print(topic)
print(val)
# TODO: implement this
option = { # for development
"kafka_url": SOME_KAFKA_URL,
"api_url": SOME_API_URL
}
mdalib.subscribe(option, cb=test)
ชื่อ topic | ความหมาย |
---|---|
message |
ข้อมูล message จาก API |
message_increase |
ข้อมูล message จาก Streaming |
internet |
ข้อมูล internet จาก API |
internet_increase |
ข้อมูล internet จาก Streaming |
call |
ข้อมูล call จาก API |
call_increase |
ข้อมูล call จาก Streaming |
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
mdalib-0.1.8.tar.gz
(2.6 kB
view hashes)
Built Distribution
mdalib-0.1.8-py3-none-any.whl
(4.1 kB
view hashes)