Getting started with Workflows

1. In the top-right corner, click Create function.
2. Enter the function name: filter-function.
3. Click Create.

1. In the Editor window that opens, select Node.js 18.
2. Disable the Add files with code examples option.
3. Click Continue.
4. Create a file named index.js and add the following code into it:

   module.exports.handler = async function (data, context) {
       return {
           id: data.id,
           name: data.name,
           email: data.email,
       };
   };
   

5. Under Parameters, specify the following in the field:
   • Entry point: index.handler
   • Service account: sa-for-function
6. Click Save changes.

1. In the top-right corner, click Create function.
2. Enter the function name: return-function.
3. Click Create.

1. In the Editor window that opens, select Node.js 18.
2. Disable the Add files with code examples option.
3. Click Continue.
4. Create a file named index.js and add the following code into it:

   module.exports.handler = async function (data, context) {
       return {
           result: "OK",
           emails: data.loaded_users.map(p => p.email)
       };
   };
   

5. Under Parameters, specify the following in the field:
   • Entry point: index.handler
   • Service account: sa-for-function
6. Click Save changes.

In the management console, select Serverless Integrations from the list of services.

In the left-hand panel, select Workflows.

In the top-right corner, click Create workflow.

In the YaML specification field, add the specification below. Specify the following in the functionId field:

• In the process_user_transform_info step, the filter-function ID.
• In the upload_users step, the return-function ID.

yawl: "0.1"
start: get_users
defaultRetryPolicy:
  maxDelay: 10s
  retryCount: 2
  errorList:
    - STEP_QUOTA_EXCEEDED
steps:
  get_users:
    httpCall:
      url: 'https://jsonplaceholder.typicode.com/\(.resource_type)'
      method: GET
      headers: {}
      query: {}
      output: '\({loaded_users: .})'
      next: process_users
  process_users:
    foreach:
      input: \(.loaded_users)
      output: '\({loaded_users: .})'
      next: upload_users
      do:
        start: process_user_get_info
        steps:
          process_user_get_info:
            httpCall:
              url: https://jsonplaceholder.typicode.com/users/\(.id)
              method: GET
              headers: {}
              query: {}
              next: process_user_transform_info
              output: '\({user: .})'
              retryPolicy:
                retryCount: 2
                errorList:
                  - HTTP_CALL_500
          process_user_transform_info:
            functionCall:
              functionId: <function_ID>
  upload_users:
    functionCall:
      functionId: "<function_ID>"
      input: '\({loaded_users, resource_type})'

Expand the Additional parameters section:

In the Name field, enter the workflow name.

In the Service account field, select the sa-for-function service account.

Click Create.