Repeating query to MongoDB every second in Python
I am running two Python scripts at the same time. The first one sends every 5 seconds a random number to my db. The one below connects to the DB and fetches every document from there.
The problem is that, when i run both of them at the same time on my console, i see data being added to the DB but the new data won't show up on the script below. To see the new data i have to close and run again it. What am i doing wrong?
from pymongo import MongoClient
import time
import random
from pprint import pprint
#Step 1: Connect to MongoDB - Note: Change connection string as needed
client = MongoClient(port=27017)
arr =
db = client.one
mycol = client["coll"]
cursor = db.mycol.find()
while True:
for document in cursor:
print(document['num'])
python mongodb
asked Nov 12 '18 at 22:29
Dev012
327
add a comment |
I am running two Python scripts at the same time. The first one sends every 5 seconds a random number to my db. The one below connects to the DB and fetches every document from there.
The problem is that, when i run both of them at the same time on my console, i see data being added to the DB but the new data won't show up on the script below. To see the new data i have to close and run again it. What am i doing wrong?
from pymongo import MongoClient
import time
import random
from pprint import pprint
#Step 1: Connect to MongoDB - Note: Change connection string as needed
client = MongoClient(port=27017)
arr =
db = client.one
mycol = client["coll"]
cursor = db.mycol.find()
while True:
for document in cursor:
print(document['num'])
python mongodb
asked Nov 12 '18 at 22:29
Dev012
327
1
"Repeating the query every second" is probably not what you really want here. Instead read Change Streams or in older releases basically look for "tailing the oplog" for that that new feature gives a more modern "contained" access to. That's a lot more durable than scheduling repeated query operations just to "see new items", which is what your intent appears to be from the content of your question.
– Neil Lunn
Nov 13 '18 at 0:40
add a comment |
I am running two Python scripts at the same time. The first one sends every 5 seconds a random number to my db. The one below connects to the DB and fetches every document from there.
The problem is that, when i run both of them at the same time on my console, i see data being added to the DB but the new data won't show up on the script below. To see the new data i have to close and run again it. What am i doing wrong?
from pymongo import MongoClient
import time
import random
from pprint import pprint
#Step 1: Connect to MongoDB - Note: Change connection string as needed
client = MongoClient(port=27017)
arr =
db = client.one
mycol = client["coll"]
cursor = db.mycol.find()
while True:
for document in cursor:
print(document['num'])
python mongodb
asked Nov 12 '18 at 22:29
Dev012
327
I am running two Python scripts at the same time. The first one sends every 5 seconds a random number to my db. The one below connects to the DB and fetches every document from there.
The problem is that, when i run both of them at the same time on my console, i see data being added to the DB but the new data won't show up on the script below. To see the new data i have to close and run again it. What am i doing wrong?
from pymongo import MongoClient
import time
import random
from pprint import pprint
#Step 1: Connect to MongoDB - Note: Change connection string as needed
client = MongoClient(port=27017)
arr =
db = client.one
mycol = client["coll"]
cursor = db.mycol.find()
while True:
for document in cursor:
print(document['num'])
python mongodb
python mongodb
asked Nov 12 '18 at 22:29
Dev012
327
asked Nov 12 '18 at 22:29
Dev012
327
asked Nov 12 '18 at 22:29
Dev012
327
asked Nov 12 '18 at 22:29
Dev012
327
asked Nov 12 '18 at 22:29
Dev012
327
327
1
"Repeating the query every second" is probably not what you really want here. Instead read Change Streams or in older releases basically look for "tailing the oplog" for that that new feature gives a more modern "contained" access to. That's a lot more durable than scheduling repeated query operations just to "see new items", which is what your intent appears to be from the content of your question.
– Neil Lunn
Nov 13 '18 at 0:40
add a comment |
1
"Repeating the query every second" is probably not what you really want here. Instead read Change Streams or in older releases basically look for "tailing the oplog" for that that new feature gives a more modern "contained" access to. That's a lot more durable than scheduling repeated query operations just to "see new items", which is what your intent appears to be from the content of your question.
– Neil Lunn
Nov 13 '18 at 0:40
1
1
"Repeating the query every second" is probably not what you really want here. Instead read Change Streams or in older releases basically look for "tailing the oplog" for that that new feature gives a more modern "contained" access to. That's a lot more durable than scheduling repeated query operations just to "see new items", which is what your intent appears to be from the content of your question.
– Neil Lunn
Nov 13 '18 at 0:40
"Repeating the query every second" is probably not what you really want here. Instead read Change Streams or in older releases basically look for "tailing the oplog" for that that new feature gives a more modern "contained" access to. That's a lot more durable than scheduling repeated query operations just to "see new items", which is what your intent appears to be from the content of your question.
– Neil Lunn
Nov 13 '18 at 0:40
add a comment |
1 Answer
1
active
oldest
votes
You have to move the 'db.mycol.find()' into the loop and also you are missing the 'time.sleep(5)' in the loop.
answered Nov 12 '18 at 22:32
Bernhard
5,70712736
I moved that line into my While loop but it still seems not to work, think my Whole code is wrong and i should try to think it in completely another way
– Dev012
Nov 12 '18 at 22:41
add a comment |
Your Answer
StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");
StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});
function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});
}
});
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53271018%2frepeating-query-to-mongodb-every-second-in-python%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
1 Answer
1
active
oldest
votes
1 Answer
1
active
oldest
votes
active
oldest
votes
active
oldest
votes
You have to move the 'db.mycol.find()' into the loop and also you are missing the 'time.sleep(5)' in the loop.
answered Nov 12 '18 at 22:32
Bernhard
5,70712736
I moved that line into my While loop but it still seems not to work, think my Whole code is wrong and i should try to think it in completely another way
– Dev012
Nov 12 '18 at 22:41
add a comment |
You have to move the 'db.mycol.find()' into the loop and also you are missing the 'time.sleep(5)' in the loop.
answered Nov 12 '18 at 22:32
Bernhard
5,70712736
I moved that line into my While loop but it still seems not to work, think my Whole code is wrong and i should try to think it in completely another way
– Dev012
Nov 12 '18 at 22:41
add a comment |
You have to move the 'db.mycol.find()' into the loop and also you are missing the 'time.sleep(5)' in the loop.
answered Nov 12 '18 at 22:32
Bernhard
5,70712736
You have to move the 'db.mycol.find()' into the loop and also you are missing the 'time.sleep(5)' in the loop.
answered Nov 12 '18 at 22:32
Bernhard
5,70712736
answered Nov 12 '18 at 22:32
Bernhard
5,70712736
answered Nov 12 '18 at 22:32
Bernhard
5,70712736
answered Nov 12 '18 at 22:32
Bernhard
5,70712736
5,70712736
I moved that line into my While loop but it still seems not to work, think my Whole code is wrong and i should try to think it in completely another way
– Dev012
Nov 12 '18 at 22:41
add a comment |
I moved that line into my While loop but it still seems not to work, think my Whole code is wrong and i should try to think it in completely another way
– Dev012
Nov 12 '18 at 22:41
I moved that line into my While loop but it still seems not to work, think my Whole code is wrong and i should try to think it in completely another way
– Dev012
Nov 12 '18 at 22:41
I moved that line into my While loop but it still seems not to work, think my Whole code is wrong and i should try to think it in completely another way
– Dev012
Nov 12 '18 at 22:41
add a comment |
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Some of your past answers have not been well-received, and you're in danger of being blocked from answering.
Please pay close attention to the following guidance:
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53271018%2frepeating-query-to-mongodb-every-second-in-python%23new-answer', 'question_page');
}
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
1
"Repeating the query every second" is probably not what you really want here. Instead read Change Streams or in older releases basically look for "tailing the oplog" for that that new feature gives a more modern "contained" access to. That's a lot more durable than scheduling repeated query operations just to "see new items", which is what your intent appears to be from the content of your question.
– Neil Lunn
Nov 13 '18 at 0:40