|
| 1 | +# Manifest for ibm-cloud-functions-data-processing-message-hub |
| 2 | +# Repo is located at https://github.com/IBM/ibm-cloud-functions-data-processing-message-hub |
| 3 | +# Installing openwhisk actions, triggers, and rules for Message Hub sample app |
| 4 | + |
| 5 | +# Deployment using this manifest file creates following OpenWhisk components: |
| 6 | +# Package: data-processing-message-hub |
| 7 | +# Action: data-processing-message-hub/receive-consume |
| 8 | +# Action: data-processing-message-hub/transform-produce |
| 9 | +# Sequence: data-processing/message-processing-sequence |
| 10 | +# Trigger: message-trigger |
| 11 | +# Rule: message-rule |
| 12 | + |
| 13 | +# This manifest file expects following env. variables: |
| 14 | +# KAFKA_INSTANCE |
| 15 | +# SRC_TOPIC |
| 16 | +# DEST_TOPIC |
| 17 | +packages: |
| 18 | + data-processing-message-hub: |
| 19 | + actions: |
| 20 | + # Action named "receive-consume" |
| 21 | + # Creating action as a regular Node.js action |
| 22 | + receive-consume: |
| 23 | + function: actions/receive-consume.js |
| 24 | + # Action named "transform-produce" |
| 25 | + transform-produce: |
| 26 | + function: actions/transform-produce.js |
| 27 | + inputs: |
| 28 | + topic: $DEST_TOPIC |
| 29 | + kafka: $KAFKA_INSTANCE |
| 30 | + sequences: |
| 31 | + # Sequence named "message-processing-sequence" |
| 32 | + # Creating the sequence that links the get and post actions |
| 33 | + message-processing-sequence: |
| 34 | + actions: receive-consume, transform-produce |
| 35 | + triggers: |
| 36 | + # Creating the message-trigger trigger" |
| 37 | + message-trigger: |
| 38 | + feed: Bluemix_$KAFKA_INSTANCE_Credentials-1/messageHubFeed |
| 39 | + inputs: |
| 40 | + isJSONData: true |
| 41 | + topic: $SRC_TOPIC |
| 42 | + rules: |
| 43 | + # Rule named "message-rule" |
| 44 | + # Creating the rule that links the trigger to the sequence |
| 45 | + kafka-inbound-rule: |
| 46 | + trigger: message-trigger |
| 47 | + action: message-processing-sequence |
| 48 | + |
0 commit comments