运行Webhook Service
园区智能体的算法服务支持的输出类型为Webhook。在创建作业前您需确保Webhook Service已运行成功。
下面以一个简单的python脚本作为示例,展示如何启动Webhook Service并保存接收的数据。
- 准备一台本地的Linux服务器,确保Linux服务器和边缘节点服务器网络通畅,并已安装python环境。
- 使用ifconfig命令在Linux服务器上查询服务器IP地址。
- 修改示例脚本第18行,填入服务器IP地址。
图1 示例脚本
import json from wsgiref.simple_server import make_server def application(environ, start_response): start_response('200 OK', [('Content-Type', 'application/json')]) request_body = environ["wsgi.input"].read(int(environ.get("CONTENT_LENGTH", 0))) f=open('./post.txt','a') f.write(request_body) f.write("\n") f.close() return ("200 success\n") if __name__ == "__main__": port = 6006 httpd = make_server("10.10.10.1", port, application) print "serving http on port {0}...".format(str(port)) httpd.serve_forever()
脚本中的端口6006可以根据用户实际需要修改。
创建作业时,算法输出Webhook URL设置为:http://${IP}:${port}。例如:http://10.10.10.1:6006。
- 执行脚本,启动Webhook Service。
图2 执行脚本成功