cannot finish lab4 function chaining. See openfaas/workshop#191

lab4/.gitignore

@@ -0,0 +1,2 @@
+template
+build

lab4/astronaut-finder.yml

@@ -0,0 +1,12 @@
+version: 1.0
+provider:
+ name: openfaas
+ gateway: http://127.0.0.1:8080
+functions:
+ astronaut-finder:
+ lang: python3
+ handler: ./astronaut-finder
+ image: ${DOCKER_USER:-dev}/astronaut-finder:latest
+ environment:
+ write_debug: true
+

lab4/astronaut-finder/handler.py

@@ -0,0 +1,10 @@
+import requests
+import random
+
+def handle(req):
+ r = requests.get("http://api.open-notify.org/astros.json")
+ result = r.json()
+ index = random.randint(0, len(result["people"])-1)
+ name = result["people"][index]["name"]
+
+ return "%s is in space" % (name)

lab4/astronaut-finder/requirements.txt

@@ -0,0 +1 @@
+requests

lab4/example.yml

@@ -0,0 +1,15 @@
+version: 1.0
+provider:
+ name: openfaas
+ gateway: http://127.0.0.1:8080
+functions:
+ first:
+ lang: python3
+ handler: ./first
+ image: cheimu/first:latest
+
+ second:
+ lang: python3
+ handler: ./second
+ image: cheimu/second:latest
+

lab4/first/handler.py

@@ -0,0 +1,7 @@
+def handle(req):
+ """handle a request to the function
+ Args:
+ req (str): request body
+ """
+
+ return req

lab4/hello-openfaas.yml

@@ -0,0 +1,12 @@
+version: 1.0
+provider:
+ name: openfaas
+ gateway: http://127.0.0.1:8080
+functions:
+ hello-openfaas:
+ lang: python3
+ handler: ./hello-openfaas
+ image: cheimu/hello-openfaas:latest
+ environment:
+ combine_output: false
+

lab4/hello-openfaas/handler.py

@@ -0,0 +1,7 @@
+import sys
+import json
+
+def handle(req):
+
+ sys.stderr.write("This should be an error message.\n")
+ return json.dumps({"Hello": "OpenFaaS"})

lab4/ingest-file.yml

@@ -0,0 +1,13 @@
+version: 1.0
+provider:
+ name: openfaas
+ gateway: http://127.0.0.1:8080
+functions:
+ ingest-file:
+ lang: python3
+ handler: ./ingest-file
+ image: cheimu/ingest-file:latest
+ readonly_root_filesystem: true
+ environment:
+ save_path: "/tmp/"
+

lab4/ingest-file/handler.py

@@ -0,0 +1,17 @@
+import os
+import time
+
+def handle(req):
+ # Read the path or a default from environment variable
+ path = os.getenv("save_path", "/home/app/")
+
+ # generate a name using the current timestamp
+ t = time.time()
+ file_name = path + str(t)
+
+ # write a file
+ with open(file_name, "w") as f:
+ f.write(req)
+ f.close()
+
+ return file_name

lab4/message.txt

@@ -0,0 +1 @@
+Hello function

lab4/request-markdown.yml

@@ -0,0 +1,10 @@
+version: 1.0
+provider:
+ name: openfaas
+ gateway: http://127.0.0.1:8080
+functions:
+ request-markdown:
+ lang: python3
+ handler: ./request-markdown
+ image: cheimu/request-markdown:latest
+

lab4/request-markdown/handler.py

@@ -0,0 +1,22 @@
+import os
+import requests
+import sys
+
+def handle(req):
+ """handle a request to the function
+ Args:
+ req (str): request body
+ """
+
+ gateway_hostname = os.getenv("gateway_hostname", "gateway") # uses a default of "gateway" for when "gateway_hostname" is not set
+
+ test_sentence = req
+
+ r = requests.get("http://" + "127.0.0.1" + ":8080/function/markdown", data= test_sentence)
+
+ if r.status_code != 200:
+ sys.exit("Error with markdown, expected: %d, got: %d\n" % (200, r.status_code))
+
+ result = r.json()
+
+ return result

lab4/request-markdown/requirements.txt

@@ -0,0 +1 @@
+requests

lab4/request-sentiment-analysis.yml

@@ -0,0 +1,10 @@
+version: 1.0
+provider:
+ name: openfaas
+ gateway: http://127.0.0.1:8080
+functions:
+ request-sentiment-analysis:
+ lang: python3
+ handler: ./request-sentiment-analysis
+ image: cheimu/request-sentiment-analysis:latest
+

lab4/request-sentiment-analysis/handler.py

@@ -0,0 +1,24 @@
+import os
+import requests
+import sys
+
+def handle(req):
+ """handle a request to the function
+ Args:
+ req (str): request body
+ """
+
+ #gateway_hostname = os.getenv("gateway_hostname", "gateway") # uses a default of "gateway" for when "gateway_hostname" is not set
+
+ test_sentence = req
+
+ r = requests.get("http://127.0.0.1:8080/function/sentimentanalysis", data= test_sentence)
+
+ if r.status_code != 200:
+ sys.exit("Error with sentimentanalysis, expected: %d, got: %d\n" % (200, r.status_code))
+
+ result = r.json()
+ if result["polarity"] > 0.45:
+ return "That was probably positive"
+ else:
+ return "That was neutral or negative"

lab4/request-sentiment-analysis/requirements.txt

@@ -0,0 +1 @@
+requests

lab4/second/handler.py

@@ -0,0 +1,7 @@
+def handle(req):
+ """handle a request to the function
+ Args:
+ req (str): request body
+ """
+
+ return req

lab4/sorter.yml

@@ -0,0 +1,10 @@
+version: 1.0
+provider:
+ name: openfaas
+ gateway: http://127.0.0.1:8080
+functions:
+ sorter:
+ lang: dockerfile
+ handler: ./sorter
+ image: cheimu/sorter:latest
+

lab4/sorter/Dockerfile

@@ -0,0 +1,27 @@
+FROM ghcr.io/openfaas/classic-watchdog:0.1.5 as watchdog
+
+FROM alpine:3.12
+
+RUN mkdir -p /home/app
+
+COPY --from=watchdog /fwatchdog /usr/bin/fwatchdog
+RUN chmod +x /usr/bin/fwatchdog
+
+# Add non root user
+RUN addgroup -S app && adduser app -S -G app
+RUN chown app /home/app
+
+WORKDIR /home/app
+
+USER app
+
+# Populate example here - i.e. "cat", "sha512sum" or "node index.js"
+ENV fprocess="sort"
+# Set to true to see request in function logs
+ENV write_debug="false"
+
+EXPOSE 8080
+
+HEALTHCHECK --interval=3s CMD [ -e /tmp/.lock ] || exit 1
+
+CMD ["fwatchdog"]