Lab 1: MQTT Input and Output Binding

  • Apply function manifest, and check running states

    $ kubectl apply -f async-bindings.yaml
    function.core.openfunction.io/sample-node-async-bindings created
    
    $ kubectl get fn
    NAME                         BUILDSTATE   SERVINGSTATE   BUILDER   SERVING         URL      AGE
    sample-node-async-bindings   Skipped      Running                  serving-8f7xc            140m
    
    $ kubectl get po
    NAME                                                   READY   STATUS    RESTARTS   AGE
    serving-8f7xc-deployment-v200-l78xc-564c6b5bf7-vksg7   2/2     Running   0          141m
  • Furthermore, check whether function container output correct logs

    $ kubectl logs -c function serving-8f7xc-deployment-v200-l78xc-564c6b5bf7-vksg7
    ...
    [Dapr-JS] Listening on 8080
    [Dapr-JS] Letting Dapr pick-up the server (Maximum 60s wait time)
    [Dapr-JS] - Waiting till Dapr Started (#0)
    [Dapr-JS] Server Started