fw
/
yzk_wechat_event
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

转化外部用户Id

This commit is contained in:
AKW 2023-12-26 10:16:56 +08:00
parent af56a72fc1
commit b55a49aaf7
3 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/jqr/pubsub.py
View File

@ -14,7 +14,7 @@ logger = logging.getLogger('apps')
class JQREventCallbackPubSub: class JQREventCallbackPubSub:
rc = get_redis_connection() rc = get_redis_connection('pubsub')
@classmethod @classmethod
def publish(cls, data): def publish(cls, data):
@ -36,7 +36,7 @@ class JQREventCallbackPubSub:
class JQREventNewUserCallbackPubSub: class JQREventNewUserCallbackPubSub:
rc = get_redis_connection() rc = get_redis_connection('pubsub')
@classmethod @classmethod
def publish(cls, data): def publish(cls, data):
@ -58,7 +58,7 @@ class JQREventNewUserCallbackPubSub:
class JQRQrcodeCallbackPubSub: class JQRQrcodeCallbackPubSub:
rc = get_redis_connection() rc = get_redis_connection('pubsub')
@classmethod @classmethod
def publish(cls, data): def publish(cls, data):

2
apps/msg/pubsub.py
View File

@ -14,7 +14,7 @@ logger = logging.getLogger('apps')
class JQRMSGPubSub: class JQRMSGPubSub:
rc = get_redis_connection() rc = get_redis_connection('pubsub')
msg_list = [] msg_list = []
BATCH_SIZE = 100 BATCH_SIZE = 100

9
yzk_wechat_event/settings/base.py
View File

@ -144,6 +144,15 @@ CACHES = {
"CLIENT_CLASS": "django_redis.client.DefaultClient", "CLIENT_CLASS": "django_redis.client.DefaultClient",
# "PASSWORD": REDIS_PASSWORD, # "PASSWORD": REDIS_PASSWORD,
} }
},
'pubsub': {
"BACKEND": "django_redis.cache.RedisCache",
"LOCATION": f"{REDIS_URI}/11",
"OPTIONS": {
"IGNORE_EXCEPTIONS": True,
"CLIENT_CLASS": "django_redis.client.DefaultClient",
# "PASSWORD": REDIS_PASSWORD,
}
} }
} }