some questions about the queue_id ......

[furuiyang0715]

I should transform the string into ObjectId, if I want to query and delete it from the mongodb ...

        for queue_id in to_delete:

            # transform
            import bson
            queue_id = bson.ObjectId(queue_id)

            try:
                self.mongo.delete_from_queue({'_id': queue_id})
            except Exception as e:
                self.logger.error('Cannot delete document from queue Error: ' + str(e))

[furuiyang0715]

Hello, I feel happy to know your excellent code, however, I am not very good at English，I try to express my point clearly ...
If I have a primary key with the int type, and I transform it into str here, I can't find the data to delete by using "self.mongo.delete(doc=doc['values'], schema=doc['schema'], collection=doc['table'], primary_key=primary_key)"

the same problem appears here：

I think it's because when parse the dumpfile, "int--> str" by "doc[child.attrib['name']] = child.text"

but when we use python-mysql-replication, it can keep "int" still "int" ....

I think it can be solved like this:

thank you a lot......