Reprocessar a quarentena

POST

/connectors/{connectorId}/quarantine/reprocess

const url = 'https://api-connect.zoppy.com.br/connectors/2489E9AD-2EE2-8E00-8EC9-32D5F69181C0/quarantine/reprocess';
const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: '{"itemIds":["2489E9AD-2EE2-8E00-8EC9-32D5F69181C0"],"confirmationToken":"example"}'
};

try {
  const response = await fetch(url, options);
  const data = await response.json();
  console.log(data);
} catch (error) {
  console.error(error);
}

curl --request POST \
  --url https://api-connect.zoppy.com.br/connectors/2489E9AD-2EE2-8E00-8EC9-32D5F69181C0/quarantine/reprocess \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '{ "itemIds": [ "2489E9AD-2EE2-8E00-8EC9-32D5F69181C0" ], "confirmationToken": "example" }'

Com o token da prévia, abre uma execução reprocess da versão publicada que recebe os registros em ctx.input.quarantined. O que ela não mandar de volta para a quarentena sai como resolvido quando ela termina bem.

Authorizations

bearer

Parameters

Path Parameters

connectorId

required

Id do conector

string format: uuid

Id do conector

Request Body^required

application/json

object

itemIds

required

Os itemIds devolvidos pela prévia

Array<string>

>= 1 items <= 500 items

confirmationToken

required

O token da prévia

string

>= 1 characters

Example ^generated

{
  "itemIds": [
    "2489E9AD-2EE2-8E00-8EC9-32D5F69181C0"
  ],
  "confirmationToken": "example"
}

Responses

200

A execução de reprocesso

application/json

A execução de reprocesso, igual a um item da lista de execuções; recebe os registros em ctx.input.quarantined

object

required

Id da execução

string format: uuid

connectorId

required

Id do conector

string format: uuid

versionSeq

required

Versão do conector que rodou

integer

trigger

required

O que começou

string

Allowed values: cron manual rehearsal reprocess

mode

required

Live grava de verdade; dry_run é ensaio

string

Allowed values: live dry_run

rehearsalScope

required

Escopo do ensaio; null numa real

string

nullable

Allowed values: sample full

status

required

Situação da execução

string

Allowed values: running succeeded partial failed timed_out

failureReason

required

Por que falhou ou estourou o tempo (error, time, slices, calls, quarantine, crash…)

string

nullable

cut

required

Ensaio amostra que parou com mais a ler

boolean

slices

required

Fatias já fechadas

integer

counters

required

Contadores de ctx.count, por objeto

object

key

additional properties

object

read

required

Registros lidos da origem

integer

created

required

Registros criados no destino

integer

updated

required

Registros atualizados no destino

integer

skipped

required

Registros sem nada a mudar

integer

failed

required

Registros que falharam

integer

quarantined

required

Registros que a execução mandou para a quarentena

integer

externalWritesSent

required

Escritas que saíram de verdade para outro sistema

integer

writesHeldBack

required

Escritas de uma execução real que não saíram: guardadas para confirmação ou planejadas atrás dela

integer

cursorKept

required

Execução real com escrita que não saiu: o ponto de onde ela parou não vale, a próxima recomeça do último ponto bom

boolean

waitingWriteConfirmation

required

A primeira escrita num sistema ficou guardada e espera a confirmação de uma pessoa

boolean

writesAsReads

required

POST/PUT/PATCH/DELETE feitos como leitura (ctx.http.request)

Array<object>

object

method

required

Método HTTP da leitura que não foi GET

string

host

required

Host chamado

string

path

required

Caminho chamado, sem query

string

count

required

Quantas vezes a execução fez essa chamada

integer

blockingIssues

required

Problemas do ensaio que impedem publicar mesmo com status succeeded; connect.write_without_lookup: um POST criou registro sem consulta anterior na mesma coleção

Array<object>

object

code

required

Código estável do problema (connect.write_without_lookup)

string

message

required

O que está errado e como corrigir, em português

string

method

required

Método da chamada que causou o problema

string

host

required

Host da chamada

string

path

required

Caminho da chamada

string

count

required

Quantas vezes aconteceu na execução

integer

startedAt

required

Início

string format: date-time

finishedAt

required

Fim; null enquanto roda

string format: date-time

nullable

Example

{
  "trigger": "cron",
  "mode": "live",
  "rehearsalScope": "sample",
  "status": "running"
}

400

Corpo inválido

application/json

object

type

required

Código estável do erro, para máquinas (ex.: connect.connector_not_found)

string

title

required

Nome da classe do erro

string

status

required

Status HTTP

integer

detail

required

Mensagem em pt-BR, segura para mostrar a quem usa a tela

string

requestId

required

Id de correlação: passe ao suporte para achar o rastro completo

string

nullable

meta

Detalhes estruturados seguros para a tela (erros de campo, ids)

object

key

additional properties

Example ^generated

{
  "type": "example",
  "title": "example",
  "status": 1,
  "detail": "example",
  "requestId": "example",
  "meta": {
    "additionalProperty": "example"
  }
}

401

Token ausente, inválido ou expirado (connect.unauthorized)

application/json

object

type

required

Código estável do erro, para máquinas (ex.: connect.connector_not_found)

string

title

required

Nome da classe do erro

string

status

required

Status HTTP

integer

detail

required

Mensagem em pt-BR, segura para mostrar a quem usa a tela

string

requestId

required

Id de correlação: passe ao suporte para achar o rastro completo

string

nullable

meta

Detalhes estruturados seguros para a tela (erros de campo, ids)

object

key

additional properties

Example ^generated

{
  "type": "example",
  "title": "example",
  "status": 1,
  "detail": "example",
  "requestId": "example",
  "meta": {
    "additionalProperty": "example"
  }
}

403

Papel sem acesso ou Connect não liberado (connect.forbidden_role, connect.feature_disabled)

application/json

object

type

required

Código estável do erro, para máquinas (ex.: connect.connector_not_found)

string

title

required

Nome da classe do erro

string

status

required

Status HTTP

integer

detail

required

Mensagem em pt-BR, segura para mostrar a quem usa a tela

string

requestId

required

Id de correlação: passe ao suporte para achar o rastro completo

string

nullable

meta

Detalhes estruturados seguros para a tela (erros de campo, ids)

object

key

additional properties

Example ^generated

{
  "type": "example",
  "title": "example",
  "status": 1,
  "detail": "example",
  "requestId": "example",
  "meta": {
    "additionalProperty": "example"
  }
}

404

Um dos registros não está aberto

application/json

object

type

required

Código estável do erro, para máquinas (ex.: connect.connector_not_found)

string

title

required

Nome da classe do erro

string

status

required

Status HTTP

integer

detail

required

Mensagem em pt-BR, segura para mostrar a quem usa a tela

string

requestId

required

Id de correlação: passe ao suporte para achar o rastro completo

string

nullable

meta

Detalhes estruturados seguros para a tela (erros de campo, ids)

object

key

additional properties

Example

{
  "type": "connect.quarantine_item_not_found",
  "title": "Este registro não está mais na quarentena.",
  "status": 404
}

409

Prévia expirada ou diferente (connect.confirmation_stale), conector desligado ou execução em andamento (connect.run_in_progress)

application/json

object

type

required

Código estável do erro, para máquinas (ex.: connect.connector_not_found)

string

title

required

Nome da classe do erro

string

status

required

Status HTTP

integer

detail

required

Mensagem em pt-BR, segura para mostrar a quem usa a tela

string

requestId

required

Id de correlação: passe ao suporte para achar o rastro completo

string

nullable

meta

Detalhes estruturados seguros para a tela (erros de campo, ids)

object

key

additional properties

Example ^generated

{
  "type": "example",
  "title": "example",
  "status": 1,
  "detail": "example",
  "requestId": "example",
  "meta": {
    "additionalProperty": "example"
  }
}

423

Pausa de emergência (connect.paused)

application/json

object

type

required

Código estável do erro, para máquinas (ex.: connect.connector_not_found)

string

title

required

Nome da classe do erro

string

status

required

Status HTTP

integer

detail

required

Mensagem em pt-BR, segura para mostrar a quem usa a tela

string

requestId

required

Id de correlação: passe ao suporte para achar o rastro completo

string

nullable

meta

Detalhes estruturados seguros para a tela (erros de campo, ids)

object

key

additional properties

Example ^generated

{
  "type": "example",
  "title": "example",
  "status": 1,
  "detail": "example",
  "requestId": "example",
  "meta": {
    "additionalProperty": "example"
  }
}

Reprocessar a quarentena

Authorizations

Parameters

Path Parameters

Request Bodyrequired

Example generated

Responses

200

Example

400

Example generated

401

Example generated

403

Example generated

404

Example

409

Example generated

423

Example generated

Request Body^required

Example ^generated

Example ^generated

Example ^generated

Example ^generated

Example ^generated

Example ^generated