0

我刚刚开始使用 Avro,我正在 Python 中使用 fastavro 库。

  1. 我准备了一个模式并用这个保存了数据。
  2. 现在,我需要附加新数据(来自 API 调用的 JSON 响应)并将其与不存在的模式一起保存到同一个 avro 文件中。我应该如何继续添加没有预定义架构的 JSON 响应并将其保存到同一个 Avro 文件中?

提前致谢。

4

1 回答 1

0

根据定义,Avro 文件中已经有一个模式。

您可以先读取该架构,然后继续追加数据,或者您可以将整个文件读入内存,然后追加数据,然后覆盖文件。

不过,每个选项都要求您将 JSON 转换为 Avro(或至少是 Python 字典)。

于 2020-08-10T23:27:12.910 回答