Code Review
/
pti
/
o2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add practice of building o2ims images inside a container
[pti/o2.git]
/
o2ims
/
adapter
/
redis_eventpublisher.py
diff --git
a/o2ims/adapter/redis_eventpublisher.py
b/o2ims/adapter/redis_eventpublisher.py
index
835c72c
..
4df167e
100644
(file)
--- a/
o2ims/adapter/redis_eventpublisher.py
+++ b/
o2ims/adapter/redis_eventpublisher.py
@@
-13,18
+13,19
@@
# limitations under the License.
import json
# limitations under the License.
import json
-import logging
from dataclasses import asdict
import redis
from o2ims import config
from o2ims.domain import events
from dataclasses import asdict
import redis
from o2ims import config
from o2ims.domain import events
-logger = logging.getLogger(__name__)
+from o2common.helper import o2logging
+logger = o2logging.get_logger(__name__)
+
r = redis.Redis(**config.get_redis_host_and_port())
def publish(channel, event: events.Event):
r = redis.Redis(**config.get_redis_host_and_port())
def publish(channel, event: events.Event):
- logg
ing
.info("publishing: channel=%s, event=%s", channel, event)
+ logg
er
.info("publishing: channel=%s, event=%s", channel, event)
r.publish(channel, json.dumps(asdict(event)))
r.publish(channel, json.dumps(asdict(event)))