我找到了一种解决方案,使该bw2analyzer.traverse_tagged_databases
功能在用于大型数据库(例如 ecoinvent)时可以正常工作。tagged.recurse_tagged_database
我通过实现计算深度(即应用递归函数的最大深度)并在达到深度时交替结果来重写函数。这是我的代码(我从原始函数中删除了一些行,因为我只使用一个数据库):
def recurse_tagged_database(activity, amount, method_dict, lca, label, default_tag, secondary_tags=[],product_system_depth=5):
from bw2data import get_activity
if isinstance(activity, tuple):
activity = get_activity(activity)
inputs = list(activity.technosphere())
if(product_system_depth > 0):
return {
'activity': activity,
'amount': amount,
'tag': activity.get(label) or default_tag,
'secondary_tags':[activity.get(t[0]) or t[1] for t in secondary_tags],
'impact': 0,
'biosphere': [{
'amount': exc['amount'] * amount,
'impact': exc['amount'] * amount * method_dict.get(exc['input'], 0),
'tag': exc.get(label) or activity.get(label) or default_tag,
'secondary_tags':[exc.get(t[0]) or activity.get(t[0]) or t[1] for t in secondary_tags]
} for exc in activity.biosphere()],
'technosphere': [recurse_tagged_database(exc.input, exc['amount'] * amount,
method_dict, lca, label,exc.get(label) or activity.get(label) or default_tag, secondary_tags,product_system_depth=product_system_depth-1)
for exc in inputs]
}
else:
return {
'activity': activity,
'amount': amount,
'tag': activity.get(label) or default_tag,
'secondary_tags':[activity.get(t[0]) or t[1] for t in secondary_tags],
'impact': redo_lca_score(lca,{activity:amount}),
'biosphere': [],
'technosphere': []
}
注释:
- 我
default_tag
在将递归函数应用于exc.get(label) or activity.get(label) or default_tag
. 实际上,就我而言,如果没有标签,我希望默认情况下将交换的影响与父活动的标签相关联。
- 就我而言,5 的深度足以得到我想要的。这已经需要一些时间了。