python - 如何通过 python 将 JSON 数据附加到存储在 Azure Blob 存储中的现有 JSON 文件？

Question

我一直在网上寻找以将数据附加到 Azure 存储中现有的 JSON 文件，我也查看了这篇文章，但它没有帮助。我有数百万条实时出现的 JSON 记录，这些记录在 python 列表中可用，我想将这些 JSON 记录附加到 azure blob 中的现有 JSON 文件中。虽然我的主要数据源是 KafkaConsumer，但我正在使用来自 Kafka 主题的数据，并且我希望这些数据以 JSON 格式存储到 Azure 存储中。因为，我正在使用 python，我不想在我的本地硬盘上读/写，我只是想如果我有 JSON 记录列表，我可以直接附加到已经在 azure 容器中的 JSON 文件。任何人都可以帮助我或提供一些参考，这对我来说会很高兴。谢谢

Answer 1

我尝试在我的系统中将数据附加到现有文件中，我将虚拟 json 数据用于测试目的，您可以传递您的 json 数据

from azure.storage.blob import AppendBlobService
import json

def append_data_to_blob(data):
  service = AppendBlobService(account_name="appendblobex", 
            account_key="key")
  data1 = {}
  data1['hi'] = 'hello'
  json_data = json.dumps(data1)
  data = json.dumps(data1)
  print(data1)
  try:
    service.append_blob_from_text(container_name="test", blob_name="test1", text = data)
  except:
     #To create the blob and append data
    #service.create_blob(container_name="test", blob_name="test1")
    service.append_blob_from_text(container_name="test", blob_name="test1", text = data)
  print('Data Appended to Blob Successfully.')


append_data_to_blob("data")

输出

下载后附加在Azure存储文件中的数据打开文件并查看数据