准备两个Filter
kn service create image-filter --image villardl/filter-nodejs:0.1 --env FILTER='event.type == "com.yang.file.image"' --scale-min=1
kn service create text-filter --image villardl/filter-nodejs:0.1 --env FILTER='event.type == "com.yang.file.text"' --scale-min=1
准备两个Subscriber
kn service create para-appender-image --image ikubernetes/appender --env MESSAGE=" - filetype/Image" --scale-min=1
kn service create para-appender-text --image ikubernetes/appender --env MESSAGE=" - filetype/Text" --scale-min=1
创建并查看parallel资源
[root@master parallel-demo]# kubectl apply -f 05-parallel.yaml
[root@master parallel-demo]# cat 05-parallel.yaml
---
apiVersion: flows.knative.dev/v1
kind: Parallel
metadata:
name: filetype-parallel
namespace: default
spec:
channelTemplate:
apiVersion: messaging.knative.dev/v1
kind: InMemoryChannel
branches:
- filter:
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: image-filter
subscriber:
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: para-appender-image
- filter:
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: text-filter
subscriber:
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: para-appender-text
reply:
ref:
apiVersion: serving.knative.dev/v1
kind: Service
name: event-display-01
[root@master parallel-demo]# kubectl get parallel
NAME URL AGE READY REASON
filetype-parallel http://filetype-parallel-kn-parallel-kn-channel.default.svc.cluster.local 71s True
curl -v "http://filetype-parallel-kn-parallel-kn-channel.default.svc.cluster.local" -X POST -H "Content-Type: application/cloudevents+json" \
-d '{"id": "say-bye", "specversion": "1.0", "type": "com.yang.file.image", "source": "sendoff", "data": {"message":"Hello Knative Parallel Flow Image"}}'
curl -v "http://filetype-parallel-kn-parallel-kn-channel.default.svc.cluster.local" -X POST -H "Content-Type: application/cloudevents+json" \
-d '{"id": "say-bye", "specversion": "1.0", "type": "com.yang.file.text", "source": "sendoff", "data": {"message":"Hello Knative Parallel Flow Text"}}'
[root@master ~]# kubectl logs event-display-01-00001-deployment-68d48cbdf8-lv9m4
原文地址:http://www.cnblogs.com/zyyang1993/p/16821172.html
1. 本站所有资源来源于用户上传和网络,如有侵权请邮件联系站长!
2. 分享目的仅供大家学习和交流,请务用于商业用途!
3. 如果你也有好源码或者教程,可以到用户中心发布,分享有积分奖励和额外收入!
4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!
5. 如有链接无法下载、失效或广告,请联系管理员处理!
6. 本站资源售价只是赞助,收取费用仅维持本站的日常运营所需!
7. 如遇到加密压缩包,默认解压密码为"gltf",如遇到无法解压的请联系管理员!
8. 因为资源和程序源码均为可复制品,所以不支持任何理由的退款兑现,请斟酌后支付下载
声明:如果标题没有注明"已测试"或者"测试可用"等字样的资源源码均未经过站长测试.特别注意没有标注的源码不保证任何可用性