Data Intelligence Modeler里的Kafka Producer和Kafka Consumer
首先本地将kafka的docker容器镜像下载到本地并运行：
docker search kafka
docker pull spotify/kafka
docker run --name kafka3 spotify/kafka
docker ps命令，查看tcp端口号：
新建一个graph，使用典型的生产者-消费者模型：将Data Generator生成的数据交给kafka Producer operator；
而Kafka Consumer从kafka producer里读取出data Generator生成的数据，通过ToString converter，输出到Terminal Operator上。
kafka producer和consumer使用的broker和topic必须一致：
运行graph，可以看到
假设我想使用浏览器访问这个处于运行状态的Graph实例：
将其Runtime handle抄下来：
43d854735c3b48a0b786905154c44817
即可在浏览器里访问了：
试图使用postman访问SAP Data Intelligence graph API时，遇到401 unauthorized的错误：
no authentication means found
取得Access Token的方法：
使用这个login API endpoint：
https://vsystem.ingress.dh-l5uukgih.dhaas-live.shoot.live.k8s-hana.ondemand.com/auth/login
注意user name的规范是tenant的名称加反斜杠加用户名。
返回的payload：
从返回的Cookie字段里获得Access Token：
然后在get API里就能anzhao Bearer
Token的方式使用这个token了：
使用HTTP GET访问SAP Data Intelligence graph API时，遇到500 internal server error的错误：
返回SAP Data Intelligence Modeler，发现graph实例执行状态处于Dead：
找到具体引起错误的process：Object Store
下载diagnosis information找到错误根源：Graph failure: SyntaxError: unexpected end of JSON input
- 点赞
- 收藏
- 关注作者
评论（0）