| 123456789101112 |
- def execute_code(loop, timeout=None):
- with BytesIO() as file_stream:
- service_principal = DefaultAzureCredential(exclude_cli_credential=True)
- future = asyncio.run_coroutine_threadsafe(
- download_blob_using_blobclient(account_name,service_principal, container_name, blob_to_read, file_stream),
- loop=loop)
- future.result(timeout)
- file_stream.flush()
- file_stream.seek(0)
- bw=TextIOWrapper(file_stream).read()
- print(bw)
- return
|
