如何用aiocoap库观察CoAP资源？

Question

我正在使用 aiocoap 库向嵌入式设备发出 CoAP 请求。通信和基本功能似乎工作正常，但文档没有说明如何启用观察。观察功能确实似乎存在于源代码中，包括服务器端和客户端——我需要客户端。

这是我目前所拥有的：GET 在服务器上创建观察状态的请求：

import asyncio, aiocoap

@asyncio.coroutine
def coap_get_with_observe():
    protocol = yield from aiocoap.Context.create_client_context()

    request = aiocoap.Message(code = aiocoap.GET)
    request.set_request_uri('coap://[aaaa::212:4b00:a49:e903]/sensors/temp')
    # set observe bit from None to 0
    request.opt.observe = 0

    try:
        response = yield from protocol.request(request).response
    except Exception as e:
        print("request failed: %s" % str(e))
    else:
        print("request ok: %r" % response.payload)

event_loop = asyncio.new_event_loop()
asyncio.set_event_loop(event_loop)
event_loop.create_task(coap_get_with_observe())
asyncio.get_event_loop().run_forever()

输出：

request ok: b'{"HDC_TEMP":2426}'

这只打印客户端收到的第一个值；我也想打印后续值。

Answer 1

替换这一行很有帮助：

    response = yield from protocol.request(request).response

有了这个：

    protocol_request = protocol.request(request)
    protocol_request.observation.register_callback(observation_callback)
    response = yield from protocol_request.response

其中 observation_callback 是定义为的函数：

def observation_callback(response):
    print("callback: %r" % response.payload)

现在，只要从服务器收到新的通知消息，就会打印消息负载。

如何用aiocoap库观察CoAP资源？

How to observe CoAP resources with aiocoap library?

python

python-3.x

python-asyncio