【发布时间】:2020-05-21 13:20:43
【问题描述】:
我正在运行以下 try-except 代码:
try:
paths = file_system_client.get_paths("{0}/{1}/0/{2}/{3}/{4}".format(container_initial_folder, container_second_folder, chronological_date[0], chronological_date[1], chronological_date[2]), recursive=True)
list_of_paths=["abfss://{0}@{1}.dfs.core.windows.net/".format(storage_container_name, storage_account_name)+path.name for path in paths if ".avro" in path.name]
except Exception as e:
if e=="AccountIsDisabled":
pass
else:
print(e)
如果我的 try-except 发生在它上面,我既不想打印以下错误,也不想在遇到这个错误时停止我的程序执行:
"(AccountIsDisabled) The specified account is disabled.
RequestId:3159a59e-d01f-0091-5f71-2ff884000000
Time:2020-05-21T13:09:03.3540242Z"
我只想overpass它并打印任何其他将发生的错误/异常(例如 TypeError、ValueError 等)。
这在 Python 3 中可行吗?
请注意,.get_paths() 方法属于 azure.storage.filedatalake 模块,该模块可以将 Python 与 Azure Data Lake 直接连接以进行路径提取。
我在注释中指出我试图绕过的异常不是内置异常。
[更新]按照建议的附加答案进行排序后,我将代码修改为:
import sys
from concurrent.futures import ThreadPoolExecutor
from azure.storage.filedatalake._models import StorageErrorException
from azure.storage.filedatalake import DataLakeServiceClient, DataLakeFileClient
storage_container_name="name1" #confidential
storage_account_name="name2" #confidential
storage_account_key="password" #confidential
container_initial_folder="name3" #confidential
container_second_folder="name4" #confidential
def datalake_connector(storage_account_name, storage_account_key):
global service_client
datalake_client = DataLakeServiceClient(account_url="{0}://{1}.dfs.core.windows.net".format("https", storage_account_name), credential=storage_account_key)
print("Client successfuly created!")
return datalake_client
def create_list_paths(chronological_date,
container_initial_folder="name3",
container_second_folder="name4",
storage_container_name="name1",
storage_account_name="name2"
):
list_of_paths=list()
print("1. success")
paths = file_system_client.get_paths("{0}/{1}/0/{2}/{3}/{4}".format(container_initial_folder, container_second_folder, chronological_date[0], chronological_date[1], chronological_date[2]), recursive=True)
print("2. success")
list_of_paths=["abfss://{0}@{1}.dfs.core.windows.net/".format(storage_container_name, storage_account_name)+path.name for path in paths if ".avro" in path.name]
print("3. success")
list_of_paths=functools.reduce(operator.iconcat, result, [])
return list_of_paths
service_client = datalake_connector(storage_account_name, storage_account_key)
file_system_client = service_client.get_file_system_client(file_system=storage_container_name)
try:
list_of_paths=[]
executor=ThreadPoolExecutor(max_workers=8)
print("Start path extraction!")
list_of_paths=[executor.submit(create_list_paths, i, container_initial_folder, storage_container_name, storage_account_name).result() for i in date_list]
except:
print("no success")
print(sys.exc_info())
不幸的是,StorageErrorException 由于某种原因无法处理,我仍然得到以下标准输出:
【问题讨论】:
-
您可以有多个
except-statements 来匹配不同类型的异常。您也可以同时匹配多个 (stackoverflow.com/questions/6470428/…)。只要您可以访问实际的异常类型,就可以了。尝试找出特定异常的定义位置并将其导入。 -
不,你在更新中做错了。你应该恢复它。
-
不要定义任何东西。只是
try:,...,except:,.... -
你不可能得到名称错误,因为你删除了所有
StorageErrorException引用。放置所有代码,而不仅仅是让人们猜测丢失的代码的部分。 -
我没有说
except StorageErrorException:。我说except:。
标签: python exception try-except