CloudFlow:Integrar o CloudFlow ao Function Compute

Conceitos principais

RequestComplete

O fluxo invoca a função e aguarda a resposta da API. Após o sistema responder e retornar o resultado, o fluxo avança para o próximo estado. Este modo funciona com invocações síncronas, invocações assíncronas e invocações de tarefas assíncronas.

Para mais informações, consulte RequestComplete.

WaitForSystemCallback

O fluxo envia a solicitação de invocação e aguarda que o Function Compute envie uma notificação de callback do sistema. O fluxo avança somente após receber esse callback. Este modo funciona apenas com invocações assíncronas e invocações de tarefas assíncronas.

Para mais informações, consulte WaitForSystemCallback.

WaitForCustomCallback

O fluxo invoca a função e entra em pausa. Ele avança somente quando seu programa chama a API de callback do CloudFlow para reportar o resultado da tarefa. Este modo funciona apenas com invocações assíncronas e invocações de tarefas assíncronas.

Para usar este modo, adicione um campo callbackToken ao parâmetro body e referencie a expressão $Context.Current.TaskToken. Este token é a credencial que seu programa deve incluir ao reportar o resultado da tarefa ao fluxo.

Type: StateMachine
Name: MyWorkflow
SpecVersion: v1
StartAt: invoke-with-callback
States:
  - Name: invoke-with-callback
    Type: Task
    Action: FC:InvokeFunction
    TaskMode: WaitForCustomCallback
    Parameters:
      resourceArn: acs:fc:::services/myService1.LATEST/functions/myFunction1
      invocationType: Async
      body:
        callbackToken.$: $Context.Current.TaskToken
        key1: value1
    End: true

Neste exemplo, o fluxo passa o token da tarefa para a função via callbackToken. A função (ou um processo downstream) chama a API ReportTaskSucceeded ou ReportTaskFailed com este token para notificar o CloudFlow do resultado.

Para mais informações, consulte WaitForCustomCallback.

Para detalhes sobre os tipos de invocação de funções, consulte Invocações síncronas, Invocações assíncronas e Gerenciamento de tarefas assíncronas.

Modo RequestComplete

O fluxo encapsula o valor retornado pela função em um objeto JSON com um campo Body:

{
    "Body": "function invocation result"
}

Acesse o valor retornado com $Output.Body nas definições de estados subsequentes. Se o valor retornado for um objeto JSON, desserialize-o com a função integrada do workflow e acesse seus membros como um objeto JSON padrão.

O exemplo a seguir invoca uma função e usa um estado Choice para ramificar com base em um valor da saída da função:

Type: StateMachine
Name: MyWorkflow
SpecVersion: v1
Description: ' '
StartAt: Example 1 of function invocation
States:
  - Name: Example 1 of function invocation
    Type: Task
    TaskMode: RequestComplete
    Action: FC:InvokeFunction
    Parameters:
      resourceArn: acs:fc:::services/myService1.LATEST/functions/myFunction1
      invocationType: Sync
      body:
        argument1.$: $Input.Records
        argument2.$: $Input.BucketName
    Next: conditional statement
  - Type: Choice
    Name: conditional statement
    Branches:
      - Condition: $Input.ObjectSize >= $Input.Threshold
        Next: Example 2 of function invocation
    Default: No action is performed.
  - Type: Pass
    Name: No action is performed.
    End: true
  - Name: Example 2 of function invocation
    Type: Task
    TaskMode: RequestComplete
    Action: FC:InvokeFunction
    Parameters:
      resourceArn: acs:fc:::services/myService2.LATEST/functions/myFunction2
      invocationType: Sync
      body:
        argument1.$: $Input.BucketName
        argument2.$: $Input.TaskId
    End: true

Modos WaitForSystemCallback e WaitForCustomCallback

Nestes modos, o sistema externo chama a API ReportTaskSucceeded ou ReportTaskFailed para reportar o resultado. O fluxo repassa o resultado sem encapsulá-lo. Por exemplo, se a função retornar {"message": "hello"}, o resultado no fluxo será:

{
    "message": "hello"
}

Acesse o valor retornado diretamente com a expressão $Output.