> ## 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.
# Incorporar datos de productos en Twenty
> Sincroniza los datos del catálogo de productos desde un almacén de datos a tu CRM según una programación.
Usa este patrón para mantener Twenty sincronizado con los datos de productos de tu almacén de datos (p. ej., Snowflake, BigQuery, PostgreSQL).
## Estructura del flujo de trabajo
1. **Disparador**: Según una programación
2. **Code**: Consultar tu almacén de datos
3. **Code** (opcional): Formatear los datos como array
4. **Iterator**: Recorrer cada producto
5. **Upsert Record**: Crear o actualizar en Twenty
## Paso 1: Programar el disparador
Configura el flujo de trabajo para ejecutarse con una frecuencia acorde a tus necesidades de actualización de datos:
* Cada 5 minutos para una sincronización casi en tiempo real
* Cada hora para datos menos críticos
* Diariamente para actualizaciones por lotes
## Paso 2: Consulta tu almacén de datos
Añade una acción **Code** para obtener datos recientes:
```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 };
};
```
Filtra por `updated_at >= last X minutes` para recuperar solo los registros cambiados recientemente. Esto mantiene la sincronización eficiente.
## Paso 3: Formatear los datos (opcional)
Si tu almacén devuelve datos en un formato que necesita transformación, añade otra acción **Code**. Las transformaciones comunes incluyen conversiones de tipo, cambio de nombre de campos y limpieza de datos.
### Ejemplo: Datos de usuario con campos booleanos y de estado
```javascript theme={null}
export const main = async (params: {
users: any;
}): Promise
## Paso 1: Programar el disparador
Configura el flujo de trabajo para ejecutarse con una frecuencia acorde a tus necesidades de actualización de datos:
* Cada 5 minutos para una sincronización casi en tiempo real
* Cada hora para datos menos críticos
* Diariamente para actualizaciones por lotes
## Paso 2: Consulta tu almacén de datos
Añade una acción **Code** para obtener datos recientes:
```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 };
};
```