> ## Documentation Index
> Fetch the complete documentation index at: https://docs.twenty.com/llms.txt
> Use this file to discover all available pages before exploring further.
# Traga dados de produtos para o Twenty
> Sincronize, de forma agendada, os dados do catálogo de produtos do seu armazém de dados para o seu CRM.
Use este padrão para manter o Twenty sincronizado com os dados de produtos do seu armazém de dados (por exemplo, Snowflake, BigQuery, PostgreSQL).
## Estrutura do Fluxo de Trabalho
1. **Gatilho**: De forma agendada
2. **Código**: Consultar seu armazém de dados
3. **Código** (opcional): Formatar os dados como array
4. **Iterador**: Percorrer cada produto
5. **Inserir/atualizar registro**: Criar ou atualizar no Twenty
## Etapa 1: Agendar o gatilho
Defina o fluxo de trabalho para executar em uma frequência que atenda às suas necessidades de atualização dos dados:
* A cada 5 minutos para sincronização quase em tempo real
* A cada hora para dados menos críticos
* Diariamente para atualizações em lote
## Etapa 2: Consultar seu armazém de dados
Adicione uma ação de **Código** para buscar dados recentes:
```javascript theme={null}
export const main = async () => {
const intervalMinutes = 10; // Match your schedule frequency
const cutoffTime = new Date(Date.now() - intervalMinutes * 60 * 1000).toISOString();
// Replace with your actual data warehouse connection
const response = await fetch("https://your-warehouse-api.com/query", {
method: "POST",
headers: {
"Authorization": "Bearer YOUR_API_KEY",
"Content-Type": "application/json"
},
body: JSON.stringify({
query: `
SELECT id, name, sku, price, stock_quantity, updated_at
FROM products
WHERE updated_at >= '${cutoffTime}'
`
})
});
const data = await response.json();
return { products: data.results };
};
```
Filtre por `updated_at >= last X minutes` para recuperar apenas registros alterados recentemente. Isso mantém a sincronização eficiente.
## Etapa 3: Formatar os dados (opcional)
Se o seu armazém de dados retornar dados em um formato que precise de transformação, adicione outra ação de **Código**. Transformações comuns incluem conversões de tipo, renomeação de campos e limpeza de dados.
### Exemplo: Dados de usuário com campos booleanos e de status
```javascript theme={null}
export const main = async (params: {
users: any;
}): Promise
## Etapa 1: Agendar o gatilho
Defina o fluxo de trabalho para executar em uma frequência que atenda às suas necessidades de atualização dos dados:
* A cada 5 minutos para sincronização quase em tempo real
* A cada hora para dados menos críticos
* Diariamente para atualizações em lote
## Etapa 2: Consultar seu armazém de dados
Adicione uma ação de **Código** para buscar dados recentes:
```javascript theme={null}
export const main = async () => {
const intervalMinutes = 10; // Match your schedule frequency
const cutoffTime = new Date(Date.now() - intervalMinutes * 60 * 1000).toISOString();
// Replace with your actual data warehouse connection
const response = await fetch("https://your-warehouse-api.com/query", {
method: "POST",
headers: {
"Authorization": "Bearer YOUR_API_KEY",
"Content-Type": "application/json"
},
body: JSON.stringify({
query: `
SELECT id, name, sku, price, stock_quantity, updated_at
FROM products
WHERE updated_at >= '${cutoffTime}'
`
})
});
const data = await response.json();
return { products: data.results };
};
```