Python Azure函数：blobclient.upload_blob授权失败

Question

import json
import requests
import azure.functions as func
from azure.storage.blob import BlobClient

def main(msg: func.QueueMessage) -> None:
             queuedata =  msg.get_body().decode('utf-8')
             data = json.loads(queuedata)
             url = data['data']['url']

             r = requests.get(url)
             data = r.text


             s1, s2 = (data.split(sep=';', maxsplit=1))
             s1 = ''.join(s1.split())

             dict1 = json.loads(s1)
             dict1 = json.loads(s2)
             mergedJson = {**dict1, **dict1}


             #connectionstring = "DefaultEndpointsProtocol=https;AccountName=XXXXXX;AccountKey=XXXXXXXX/Jm4OPgSzWOju5hD/+XA4QXXXXXXfNEbUxuO9WoUQ7xn91cE3qlQeqRoHJx3SrJ+bdln9Q==;EndpointSuffix=core.windows.net"

             sas_url = 'https://XXXXX.blob.core.windows.net/?sv=2019-10-10&ss=bq&srt=c&sp=rwdlacupx&se=2020-06-13T04:48:27Z&st=2020-06-12T20:48:27Z&spr=https&sig=1j2a6pQUFLI1B71D8oRoALHYgpF82pMiXbvrdZCY7gk%3D'
             sas_token = '?sv=XXXXXXXXXX-10-10&ss=XXXXX&XXX=c&sp=rwdlacupx&se=2020-06-13T04:48:27Z&st=2020-06-12T20:48:27Z&spr=https&sig=1j2a6pQUFLI1B71D8oRoALHYgpF82pMiXbvrdZCY7gk%3D'


             filename = dictA['FormId'] + '.json'
             #blob_client = BlobClient.from_connection_string(conn_str= connectionstring,  container_name='json', content_type='application/json', blob_name= filename)
             #blob_client.upload_blob(mergedJson, blob_type='BlockBlob')

             blob_client2 = BlobClient(account_url= sas_url, credential= sas_token, container_name='json', blob_name= filename, content_type='application/json')
             blob_client2.upload_blob(mergedJson, blob_type='BlockBlob')

结果：失败异常：ClientAuthenticationError：服务器无法对请求进行身份验证。确保包括签名在内的授权头的值是正确形成的。requestid:cdccbb2e-e01e-0007-6cfd-40c024000000时间:2020-06-12t21:09:22.1504720z错误代码：身份验证失败错误：无身份验证错误详细信息：在HTTP请求'n+okbbfhsn12nhw3siqk4oxuglaxqrc32mh93gweism='中找到的MAC签名与任何计算的签名都不相同。服务器使用以下字符串进行签名:'PUT 302 Application/Octet-Stream*X-MS-BLOB-Type:BlockBLOB X-MS-Client-Request-ID:FCBA350C-ACF0-11EA-B094-0242AC100105-X-MS-DATE:FRI，2020年6月12日21:09:22 GMT X-MS-Version:2019-07-07/DMGENHWR/JSON/C1234567.json'。堆栈：文件“/azure-functions-host/workers/python/3.7/linux/x64/azure_functions_worker/dispatcher.py”,第315行，在_handle__invocation_request self.run_sync_func,invocation_id,fi.func,args中）文件“/usr/local/lib/python3.7/concurrent/future/thread.py”,第57行，在run result=self.fn(*self.args,__run_sync_func返回func(**params)文件“/home/site/wwwroot/textqueue/__init.py”,第32行，在main blob_client.upload_blob(mergedJson,blob_type='blockblob')文件“/home/site/wwwroot/.python_packages/lib/site-packages/azure/core/tracing/decorator.py”,第83行，在wrapper_use_tracer返回func(*args,**kwargs）文件.py“，第496行，在upload_blob返回upload_block_blob(**options)文件”/home/site/wwwroot/.python_packages/lib/site-packages/azure/storage/blob/_upload_helpers.py“中，line 153,在upload_block_blob process_storage_error（错误）文件“/home/site/wwwroot/.python_packages/lib/site-packages/azure/storage/blob/_shared/response_handlers.py”中，第147行，在process_storage_error引发错误

使用BlobClient时出现SAS URL和SAS令牌错误(account_url,container_name,blob_name,snapshot=none,credential=none,**kwargs):

结果：失败异常：HttpResponseError：此请求无权使用此资源类型执行此操作。RequestId:62BB329F-B01E-0036-19FB-409BF3000000时间:2020-06-12T20:56:14.5723115 Z错误代码：AuthorizationResourceTypeMission错误：None Stack：文件“/azure-functions-host/workers/python/3.7/linux/x64/azure_functions_worker/dispatcher.py”，第315行，在_handle__invocation_request self.run_sync_func,invocation_id,fi.func,args中）文件*self.args,**self.kwargs）文件“/azure-functions-host/workers/python/3.7/linux/x64/azure_functions_worker/dispatcher.py”,第434行，在__run_sync_func返回func(**params)文件“/home/site/wwwroot/textqueue/__init.py”中，第35行，在main blob_client2.upload_blob(mergedJson,blob_type='blockblob')文件_use_tracer返回func(*args,**kwargs)文件“/home/site/wwwroot/.python_packages/lib/site-packages/azure/storage/blob/_blob_client.py”，第496行，在upload_blob r中eturn upload_block_blob(**options)文件“/home/site/wwwroot/.python_packages/lib/site-packages/azure/storage/blob/_upload_helpers.py”第153行，在upload_block_blob process_storage_error（错误）文件“/home/site/wwwroot/.python_packages/lib/site-packages/azure/storage/blob/shared/response_handlers.py”第147行，在

我引用了azure storage BlobClient类

这个函数是否需要put的Http操作方法？我在azure sdk for Python中没有看到它的引用。任何指导都是非常感谢的。

Answer 1

根据使用Azure库和Azure Storage的指南，我添加了azure-identity并按照服务原则“4A:使用blob Storage和authentication”进行身份验证

关键是为blob容器授予服务原则的权限。

我的第一次尝试是使用“4B:使用带有连接字符串的blob存储”中的指导，但没有成功。使用服务原则并遵循系统分配的托管标识和授权访问blob的指示似乎已经解决了这个问题。