通知 python orion/quantumleap 订阅更改

Question

当 Quantumleap o Orion 订阅因更改的值而触发时，有什么方法可以在 python 中得到通知吗？

我正在尝试使用此 python 代码（感谢nickjj）监听 HTTP 请求，它正在监听localhost:8008（确实有效，如果我访问监听地址，我可以看到打印的标题），但我可以从 Orion 那里得到任何通知。

from http.server import HTTPServer, BaseHTTPRequestHandler
from sys import argv

BIND_HOST = 'localhost'
PORT = 8008

class SimpleHTTPRequestHandler(BaseHTTPRequestHandler):
    def do_GET(self):
        self.write_response(b'')

    def do_POST(self):
        content_length = int(self.headers.get('content-length', 0))
        body = self.rfile.read(content_length)

        self.write_response(body)

    def write_response(self, content):
        self.send_response(200)
        self.end_headers()
        self.wfile.write(content)

        print(self.headers)
        print(content.decode('utf-8'))


if len(argv) > 1:
    arg = argv[1].split(':')
    BIND_HOST = arg[0]
    PORT = int(arg[1])

print(f'Listening on http://{BIND_HOST}:{PORT}\n')

httpd = HTTPServer((BIND_HOST, PORT), SimpleHTTPRequestHandler)
httpd.serve_forever()

我已经在 Orion 中配置了相关订阅

curl -iX POST \
    'http://localhost:1026/v2/subscriptions/' \
    -H 'Content-Type: application/json' \
    -H 'fiware-service: opcua_car' \
    -H 'fiware-servicepath: /demo' \
    -d '{
  "description": "Subscriptions for Python",
  "subject": {
    "entities": [
      {
        "idPattern": ".*",
        "type": "PLC"
      }
    ],
    "condition": {
      "attrs": [
        "processStatus"
      ]
    }
  },
  "notification": {
    "http": {
      "url": "http://localhost:8008"
    },
    "attrs": [
      "processStatus"
    ],
    "metadata": [
      "dateCreated",
      "dateModified"
    ]
  },
  "throttling": 1
}'

Answer 1

我认为接收来自 Orion 的 HTTP 通知的最简单方法是设置一个 http 服务器来监听 Python 代码中的那些通知（http 请求）。例如，使用Flask。

最好。