Build on VAST

def init(ctx):
    # One time initialization comes here
    ctx.logger.info(
        f"Initialized... {os.environ.get('FUNCTION_NAME')}")

def handler(ctx, event):
    # Events Processing comes here
    ctx.logger.info(f"Handler {event}")
    # Do stuff with the event :)
    return "Hello VAST"

#build function image
vastde functions build serverlessfunc -t /serverlessfunc

#...logging...
Build completed: serverlessfunc: initial

#...push to docker...

#create function on DataEngine
vastde functions create --name serverlessfunc \ 
--container-registry selab \
--artifact-source docker/myfunc \
--image-tag latest

Function created: serverlessfunc
Description: Basic function that prints : "Hello VAST"

#define a trigger.yaml
cat > scheduler-trigger.yaml << 'EOF'
name: schedule-1m-trigger
type: Schedule
description: "Schedule trigger that runs every minute"
tags: [every-minute]
cron_schedule: "0 * * ? * * *"
EOF

#create a trigger on DataEngine
vastde triggers create -f schedule-trigger.yaml

#...logging...
Trigger created: schedule-1m-trigger
Type: Schedule
Topic: vast:dataengine:topics:vast-workshop-broker/default

#define a pipeline-config.yaml
cat > pipeline-config.yaml << EOF
name: hello-vast-pipeline
manifest:
  triggers:
    - name: schedule-1m-trigger
  function_deployments:
    - name: hello-vast
  links:
    - source:
      - schedule-lm-trigger
      destination:
        - hello-vast
EOF

#create a pipeline on DataEngine 
#scheduler trigger --pipeline--> hello vast function
vastde pipelines create --config ~/pipelines/create-pipeline.yaml

#...logging...
Pipeline created: hello-vast-pipeline