在vscode中编写azure functions实现从数据湖指定位置的blob筛选数据咧指定位置的路径为参数path筛选的规则是SinkModifiedOn字段大于输入参数time同时相同数据只保留VersionNumber字段最大的。最后将筛选的数据写入数据湖的文件中。帮我构思需要几个函数来实现每个函数怎么写

需要编写两个Azure Functions来实现此任务：

1. 第一个函数负责获取指定路径下的Blob，并将其筛选出符合条件的数据，写入到一个队列中。

   函数签名：

   def main(myblob: func.InputStream, path: str, time: str, outputQueue: func.Out[str]):
   

   参数说明：

   • myblob：输入的Blob文件。
   • path：指定路径。
   • time：筛选条件中的时间戳。
   • outputQueue：输出队列，用于存储筛选后的数据。

   函数实现：

   import json
   import azure.functions as func
   from azure.storage.blob import BlobServiceClient
   
   def main(myblob: func.InputStream, path: str, time: str, outputQueue: func.Out[str]):
       # 获取BlobServiceClient
       blob_service_client = BlobServiceClient.from_connection_string('DefaultEndpointsProtocol=https;AccountName=<your-storage-account-name>;AccountKey=<your-storage-account-key>;EndpointSuffix=core.windows.net')
   
       # 获取BlobContainerClient
       container_client = blob_service_client.get_container_client('<your-container-name>')
   
       # 获取指定路径下的Blob列表
       blobs = container_client.list_blobs(name_starts_with=path)
   
       # 筛选出符合条件的Blob
       for blob in blobs:
           # 获取Blob的元数据
           metadata = blob_service_client.get_blob_metadata(container_client.container_name, blob.name)
           # 判断SinkModifiedOn字段是否大于输入参数time
           if metadata['SinkModifiedOn'] > time:
               # 获取Blob的内容
               blob_content = blob_service_client.download_blob(container_client.container_name, blob.name).readall()
               # 将Blob的内容转换为json格式
               blob_json = json.loads(blob_content)
               # 筛选出VersionNumber字段最大的数据
               result = max(blob_json, key=lambda x: x['VersionNumber'])
               # 将筛选后的数据写入到队列中
               outputQueue.set(json.dumps(result))
   

2. 第二个函数负责从队列中取出数据并将其写入到指定的数据湖文件中。

   函数签名：

   def main(inputQueue: func.InputStream, outputBlob: func.Out[str]):
   

   参数说明：

   • inputQueue：输入队列，用于获取筛选后的数据。
   • outputBlob：输出Blob，用于将筛选后的数据写入到数据湖文件中。

   函数实现：

   import json
   import azure.functions as func
   from azure.storage.blob import BlobServiceClient
   
   def main(inputQueue: func.InputStream, outputBlob: func.Out[str]):
       # 获取BlobServiceClient
       blob_service_client = BlobServiceClient.from_connection_string('DefaultEndpointsProtocol=https;AccountName=<your-storage-account-name>;AccountKey=<your-storage-account-key>;EndpointSuffix=core.windows.net')
   
       # 获取BlobContainerClient
       container_client = blob_service_client.get_container_client('<your-container-name>')
   
       # 获取数据湖文件的BlobClient
       blob_client = container_client.get_blob_client('<your-blob-name>')
   
       # 从队列中取出筛选后的数据，并写入到数据湖文件中
       while True:
           try:
               # 从队列中获取数据
               message = inputQueue.get()
               # 将数据转换为json格式
               data = json.loads(message.get_body().decode('utf-8'))
               # 将数据写入到数据湖文件中
               blob_client.upload_blob(json.dumps(data), overwrite=True)
           except IndexError:
               break
   ``