mongo-connector
mongo-connector copied to clipboard
yougov
MongoDB data stream pipeline tools by YouGov (adopted from MongoDB)
I just use mongo-connector index data to elasticsearch, But i find that mongo-connector can not synchronization in real time Please help me Thanks!
I've tried to install mongo-connector with python3, but I have a "/usr/bin/python: no module named 'mongo_connector'" error. I installed python3.7, then I downloaded the last get-pyp file and an `python3...
@ShaneHarvey
Since **MongoDB 3.4**, mongo provides support for creating [view](https://docs.mongodb.com/manual/core/views/). Can `mongo-connector` sync data from a view to a Es index ? Or can it be extended somehow to use a...
After install elasticsearch, mongoDB and mongo-connector, I tried to run mongo-connector -m localhost:27017 -t localhost:9400 -d elastic2_doc_manager in my local environment. It failed and the error is ``` Traceback (most...
Hi experts, I have an issues with Mongo-connector after restart server the data not sync from MongoDB to Solr although i checked the status of mongo-connector is active. After i...
OplogThread assumes that _id in the document is an ObjectId [here](https://github.com/mongodb-labs/mongo-connector/blob/master/mongo_connector/oplog_manager.py#L817) and [here](https://github.com/mongodb-labs/mongo-connector/blob/master/mongo_connector/oplog_manager.py#L831) This also assumes the _ids returned by `DocManager.search()` and `DocManager.get_last_doc()` can be coerced to ObjectId. But mongo...
Good morning! I am trying to get a grasp of the philosophy behind this connector. I have read that it is difficult to implement a filter based on values. For...
I am trying to connect my mongo cluster using `mongo-connector -m mongodb://myadmin:password@server1:27017,server2:27017,server3:27017/myCompany?authSource=admin` and it shows me > pymongo.errors.OperationFailure: there are no users authenticated So I am printing self.auth_key and self.auth_username...
There's an except for DuplicateKeyError, but bulk_op.execute will only throw BulkWriteError with the dup key error inside of it. Add a loop through the bulk write error details to pass...
