> ## 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.
# 将产品数据导入 Twenty
> 按计划将数据仓库中的产品目录数据同步到您的 CRM。
使用此模式，使 Twenty 与您的数据仓库（例如 Snowflake、BigQuery、PostgreSQL）中的产品数据保持同步。
## 工作流结构
1. **触发器**：按计划
2. **Code**：查询您的数据仓库
3. **Code**（可选）：将数据格式化为数组
4. **Iterator**：遍历每个产品
5. **Upsert Record**：在 Twenty 中创建或更新
## 步骤 1：为触发器设定计划
将工作流设置为按满足数据新鲜度需求的频率运行：
* 每 5 分钟一次，用于近实时同步
* 每小时一次，适用于不太关键的数据
* 每天一次，适用于批量更新
## 步骤 2：查询您的数据仓库
添加一个 **Code** 操作以获取最新数据：
```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 };
};
```
通过 `updated_at >= last X minutes` 进行筛选，仅检索最近更改的记录。 这样可以保持同步的高效性。
## 步骤 3：格式化数据（可选）
如果数据仓库返回的数据格式需要转换，请再添加一个 **Code** 操作。 常见的转换包括类型转换、字段重命名和数据清理。
### 示例：包含布尔值和状态字段的用户数据
```javascript theme={null}
export const main = async (params: {
users: any;
}): Promise