我是新来的python,但我知道自我是自动传递。我无法理解为什么我得到这个错误,我得到同样的错误getGraph函数以及2需要1给定。 这里怎么回事?TypeError:func()只需要1个参数(0给出)
CreateDoc是CeleryTasks.py和insert_manager在MongoTriggers.py
@app.task
def createDoc(self):
print ("CeleryTasks:CreateDoc")
if 'refs' not in self.data:
return
print(self.data['refs'])
for id in self.data['refs']:
doc = self.db[self.collName].find_one({'_id': id})
if doc is None:
insertedID = self.db[self.collName].insert_one({
"_id": id
})
print (insertedID)
#Trigger on Mongo Operations
def insert_manager(op_document):
print("Data Inserted")
# pprint.pprint (op_document)
data = op_document['o']
ns = op_document['ns'].split('.')
# pprint.pprint (data)
docID = op_document['o']['_id']
tasks = CeleryTasks(port, docID, dbName, collectionName, data)
tasks.createDoc()
tasks.getGraph.delay(docID)
嗨,哪一行会导致此错误? – user10089632
tasks.createDoc.delay() 它相当于tasks.createDoc(),这也给出了错误。 – Sam
你需要提供多长时间来延迟例子'tasks.createDoc.delay()'将延迟6秒 – user10089632