不要直接从query 调用export_json,而是将结果保存在实例属性中并返回self 以启用链接。然后export_json 在实例上查找保存的查询,而不是将其作为参数。
@dataclass
class Data_Query:
hierarchic: str
sku: bool
pred_lenght: int
def query(self, db):
if (self.hierarchic == 'store' and self.sku == True):
self.x = db.aggregate([{...}]);
# self.export_json(x)
return self
def export_json(self, file):
try:
x = self.x
except AttributeError:
return
with open(f'/home/Documents/dataset/{file}', 'w') as fp:
for i in x:
json.dump(i, fp)
fp.write('\n')
del self.x
现在你可以写data.query(db).export_json('abc.json'),和JSON文件
只有在实际上发生查询时才会写入。
但是,这并不是最棒的设计。 export_json 的任何内容都不是您的班级所特有的;它应该是一个接受结果和文件名的常规函数
并且您在进行查询之后调用 ,if 查询会返回任何结果。有点像
@dataclass
class Data_Query:
hierarchic: str
sku: bool
pred_lenght: int
def query(self, db):
if (self.hierarchic == 'store' and self.sku == True):
return db.aggregate([{...}])
def export_json(self, x, file):
with open(f'/home/Documents/dataset/{file}', 'w') as fp:
for i in x:
json.dump(i, fp)
fp.write('\n')
result = data.query(db)
if result is not None:
export_json(result, 'abc.json')
您可能争辩说“当然export_json 与我的类有关;它假定x 是对象的可迭代对象,这是由query 方法定义的。”在这种情况下,您可以考虑定义一个QueryResult 类,并使export_json 成为那个 类的方法。然后DataQuery.query 返回一个QueryResult 的实例,链接感觉不那么随意了:您导出的是result,而不是query。
# By the way, I am assuming there is more to this class than a query
# method; otherwise, there should probably just be a regular function
# that takes the db, hierarchic, and sku as arguments.
@dataclass
class DataQuery:
hierarchic: str
sku: bool
pred_length: int
def query(self, db):
result = None
if self.hierarchic == 'store' and self.sku:
result = db.aggregate(...)
return QueryResult(result)
class QueryResult:
def __init__(self, result):
self.result = result
def export_json(self, file):
if self.result is None:
return
with open(f'/home/Documents/dataset/{file}', 'w') as fp:
for i in x:
json.dump(i, fp)
fp.write('\n')
data.query(db).export_json('abc.json')