按计划将 DuckDB 同步到 Anvil.works。

自动化 · DuckDB 到 Anvil.works

保持 Anvil.works 与你的 DuckDB 文件保持一致， 按计划

只需编写一次 SQL 语句。Query Streams 会按照您设定的计划运行它，从每五分钟一次到每周一次都可以，并将结果行写入您的 Anvil.works 数据表。您可以按键匹配行，这样编辑操作就会生效，而查询未覆盖的行则会被删除，或者也可以简单地追加数据。无需 Zapier、脚本或导出功能。首次运行大约需要十五分钟，免费套餐即可满足需求。

大约15分钟 无需编程 文件位置不变 每 5 分钟到每周

你最终会得到什么

一个 Anvil.works 数据表，用于存储 DuckDB 查询返回的数据行，并按计划更新，更新频率从每五分钟到每周一次不等，每次更新都会生成一份变更记录。例如：

向 Anvil.works 下订单 积极的

每日同步 · 09:00 · Anvil.works 1643 行 · 8.8 秒

1,627行同步按密钥匹配 · 无需操作

11新的在标题下方，与标题列相同。

5更新DuckDB 中的价格已更改，已就地更新 5 行数据。

0已移除查询失败的行将从数据表中删除。

DuckDB holds your data in a file. Your team works in Anvil.works. The usual bridge is a hand-written import in your app that breaks quietly and copies one row at a time. Query Streams Automation does it differently: the Agent that already reads your DuckDB file runs your saved SQL on a schedule and writes the whole result into Anvil.works in one pass, matching rows by a key so the data table stays correct rather than growing.

你需要准备什么

查询流帐户

免费版足以满足本指南的需求。请注册： my.querystreams.com.

DuckDB 通过 Agent 连接

The Agent installed on the computer that holds your DuckDB file, or on one that reads it from a network share, with the connection added in Data Agents. Not done yet? 首先连接 DuckDB大约需要十分钟。

已保存的查询

您希望保持同步的 SELECT 语句，已保存在 查询生成器下面的步骤 1 展示了一个例子。如果您希望更改的行直接更新，请添加一个每行唯一的列，例如 ID。

您的 Anvil.works 登录信息

输入 Anvil 应用的 HTTPS 地址，以及您在应用中使用 querystreams 模块的 connector.init_connector("key") 设置的连接器密钥。Query Streams 会检查应用的响应并列出其数据表。

分六步完成设置

1. 保存要保持同步的查询

   打开 查询生成器选择你的 DuckDB 连接（尚未连接？） 从这里开始），并在 Anvil.works 中编写 SELECT 语句，使其返回所需的行和列。以下示例从中提取几列。 命令 桌子：

   示例 · SQL

   SELECT order_id, customer_name, order_total FROM main.orders ORDER BY order_total DESC LIMIT 100;

   运行它，然后 节省 给它起一个容易识别的名字，例如“Anvil.works 的订单”。在 SELECT 语句中保留一个每行都唯一的列，如下所示。 订单ID这就是完全同步功能用于就地更新行的关键所在。稍后编辑并重新保存查询，自动化程序会在下次运行时获取到这些更改。

2. 打开自动化并选择 Anvil.works

   在门户中，打开 自动化 （顶部菜单） 流 → 定时 → 自动化）并点击 新自动化巫师有五个简单的步骤。 步骤 1 点击 Anvil.works 卡片。

   开放自动化

   看到的是“开始之前”吗？ 只有当代理在线并建立连接且至少存在一个已保存的查询时，该向导才会打开。页面会列出缺少哪一项，并提供指向该查询的链接。

3. 连接 Anvil.works

   在 步骤 2 该页面将引导您完成 Anvil 端的操作：将 Query Streams 依赖项代码添加到您的应用程序中。 设置 → 依赖项 → 第三方创建一个服务器模块 从查询流导入连接器 和 connector.init_connector("你的密钥")然后点击 生成安全密钥 制作那把钥匙。然后输入你的 Anvil 应用网址 和 连接器身份验证密钥 并点击 测试连接您的应用需要 加速表 已开启（设置→数据表）；页面会自动为您重新检查。

4. 选择行的落点。

   在 步骤 3 选择 数据表 数据行应该会同步到该表中。如果您想要一个空表，请先在 Anvil 应用中创建它。如果表中已有数据行，预览会显示这些数据行，并解释每种同步模式会对其执行哪些操作。每个表只能设置一个自动化流程。

5. 选择查询语句，并决定如何显示数据行。

   在 步骤 4 打开 保存的查询 列出并选择步骤 1 中的查询。查询流会运行一次该查询以读取列，并告诉您返回的行数，以及两个选项：

   追加 · 快速

   附加

   每次运行都会将查询结果添加到数据表的底部。不会更新或删除任何数据，因此它是快速收集日志、事件和历史记录的理想选择。无需键列。未更改的行不会再次添加；值发生更改的行会作为新行添加到下方，而原行则保留。

   完全同步 · 镜像

   完全同步

   行通过以下方式匹配： 钥匙 例如订单 ID 这样的列。新行会被添加，已更改的行会就地更新，查询不再返回的行会被删除，包括用户手动输入到数据表中的行，因此请将手动输入的行保存在另一个数据表中。这是库存、销售管道、主数据和仪表盘的理想选择。

   完全同步是按列设置的，这使得它在共享数据表中非常有用：

   钥匙

   例如，标识行的列。 订单ID它在查询结果中必须是唯一的；查询流会自动检查这一点并拒绝重复项。

   同步

   每次运行都会覆盖 DuckDB 中的数据。如果有人编辑了 Anvil.works 中的同步列，下次运行会恢复源值。

   保存

   该数据行在首次到达时写入，之后不会再进行比较，因此 DuckDB 中对该数据的更改不会触发更新。对于团队手动输入的备注、所有者和后续日期，请使用完全不在查询中的列：仅存在于 Anvil.works 中的列永远不会被同步操作修改。

   哪个更快？ 追加写入操作不会先读取数据表。完全同步操作会读取数据表，比较每一行，然后只写入差异部分，因此耗时更长，但数据表始终与查询结果完全匹配。您可以稍后在自动化流程的编辑面板中切换操作。

   要查看您信任的数据表，请点击 将所有列设置为同步然后点击钥匙图标 订单ID 使其成为 钥匙查询流会扫描整个结果以确认键的唯一性，如果不是，则会发出警告。您可以将团队的备注保存在与查询无关的列中；这些列不会被修改。要查看只会不断增长的日志，请点击此处。 将所有列设置为保留 而是跳过密钥。点击 继续.

6. 设置日程，命名，创建它

   在 步骤 5 选择 按计划运行 并选择 频率:

   频率	跑
   每5分钟	每 5 分钟一次，最快允许时间
   每15分钟	每隔15分钟
   每隔30分钟	每隔30分钟
   每小时	每小时整点
   每天上午9点	每天上午 9:00，默认
   每天早上6点	每天早上6点
   工作日上午9点	周一至周五上午 9:00
   每周一（上午 9 点）	每周一上午9:00
   自定义日程	您自己的分钟、小时、星期几或月份几日。

   时代如是 时区 你选择，它最初是你浏览器的默认设置。你也可以选择 仅限手动 并按 运行 您可以随时设置计划任务；稍后可以从自动化流程的“编辑”面板添加计划任务。计划任务会在代理程序上运行，因此即使浏览器关闭，任务也会继续运行。如果运行代理程序的计算机在任务到期时处于关机状态，则会在代理程序重新启动后不久执行一次错过的运行。

   给它一个 集成名称例如“每日发往 Anvil.works 的订单”，请检查 准备创建 摘要和点击 创建自动化返回“自动化”页面，按 运行 现在就执行第一次同步，无需等待预定计划。打开 Anvil.works 文件：行就在那里，位于列标题下方。

你之后看到的

这 自动化页面 列出所有自动化流程及其状态、源、目标、键、计划、上次同步时间和行数。打开一个查看详情。 执行 标签页：记录每次运行及其触发条件（手动或计划）、持续时间以及创建、更新、删除和未更改的行数。 表现 该标签页显示 7 至 90 天内处理的数据和成功率。

这些计划允许什么？

所有套餐（包括免费套餐）都包含自动化功能，且创建的自动化数量没有限制。每个套餐的限制在于每次查询运行返回的行数：

如果查询返回的结果较多，则运行会继续进行而不是提前终止，自动化流程会告知您哪个计划更合适，或者建议添加筛选条件，例如日期范围。每次成功运行都会占用您的数据域配额，该配额与您的 Excel 和 Sheets 查询使用的配额相同。 请查看定价页面 津贴。

下一步行动不错。

• 添加筛选器 查询条件可以是最近 90 天的数据，这样数据表就能保持较小且运行速度快，并符合计划的行数限制。
• 将手写笔记单独列保存。位于查询之外，因此它们在每次同步中都能保留下来。
• 将自动化流程分组 在编辑面板中添加几个元素后，自动化页面会按组进行筛选。

Reaching a file on a network share

The Agent opens files as a background service, not as you, so a file on another computer needs one extra step. Which step depends on the computer the Agent runs on.

If the test cannot get to the share, look for these words in its result: unreachable means the Agent’s computer got no answer from the server. On Linux or a Mac, not mounted means the share still has to be mounted, and that message includes the exact mount command for your server.

Test failed on a share?

Every run reaches the file the same way the connection test does. If runs start failing after something changed on the file server, a new password for example, open the connector in 数据代理 并点击 测试连接. The test result, and the line under the file path, name the problem:

人们提出的问题

相关指南

• MySQL 到 Anvil.works
• PostgreSQL 到 Anvil.works
• Microsoft SQL Server 到 Anvil.works
• 「Anvil.works Snowflake 集成 – 自动同步实时数据库数据」的说明
• DuckDB 到 Airtable
• 如何将 DuckDB 连接到 Google Sheets
• 所有 Anvil.works 自动化指南