this repo has no description
Add logging
+16
-7
+8
feedgen.py
+8
feedgen.py
···
2
2
3
3
import asyncio
4
4
import dag_cbor
5
+
import logging
5
6
import sys
6
7
import websockets
7
8
···
13
14
from feeds.rapidfire import RapidFireFeed
14
15
from feeds.popular import PopularFeed
15
16
from firehose_manager import FirehoseManager
17
+
18
+
logging.basicConfig(
19
+
format='%(asctime)s - %(levelname)-5s - %(name)-20s - %(message)s',
20
+
level=logging.DEBUG
21
+
)
22
+
logging.getLogger('').setLevel(logging.WARNING)
23
+
logging.getLogger('feeds').setLevel(logging.DEBUG)
16
24
17
25
async def firehose_events(firehose_manager):
18
26
relay_url = 'wss://bsky.network/xrpc/com.atproto.sync.subscribeRepos'
+4
-4
feeds/popular.py
+4
-4
feeds/popular.py
···
1
1
import os
2
-
import sys
3
-
import math
2
+
import logging
4
3
import apsw
5
4
6
5
from . import BaseFeed
···
27
26
create unique index if not exists uri_idx on posts(uri);
28
27
""")
29
28
29
+
self.logger = logging.getLogger('feeds.popular')
30
+
30
31
def process_commit(self, commit):
31
32
op = commit['op']
32
33
if op['action'] != 'create':
···
47
48
), dict(uri=like_subject_uri, ts=ts))
48
49
49
50
def run_tasks_minute(self):
50
-
sys.stdout.write('popular: running minute tasks\n')
51
-
sys.stdout.flush()
51
+
self.logger.debug('running minute tasks')
52
52
53
53
with self.db_cnx:
54
54
self.db_cnx.execute(
+4
-3
feeds/rapidfire.py
+4
-3
feeds/rapidfire.py
···
1
1
import os
2
-
import sys
3
2
import apsw
3
+
import logging
4
4
5
5
from . import BaseFeed
6
6
···
27
27
create table if not exists posts (uri text, create_ts timestamp, lang text);
28
28
create index if not exists create_ts_idx on posts(create_ts);
29
29
""")
30
+
31
+
self.logger = logging.getLogger('feeds.rapidfire')
30
32
31
33
def process_commit(self, commit):
32
34
op = commit['op']
···
59
61
)
60
62
61
63
def run_tasks_minute(self):
62
-
sys.stdout.write('rapidfire: running minute tasks\n')
63
-
sys.stdout.flush()
64
+
self.logger.debug('running minute tasks')
64
65
65
66
with self.db_cnx:
66
67
self.db_cnx.execute(