Skip to content

Commit

Permalink
修改参数名称
Browse files Browse the repository at this point in the history
  • Loading branch information
Sitoi committed Jun 18, 2020
1 parent 19c9325 commit 388cdd0
Show file tree
Hide file tree
Showing 5 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ REDIS_SENTINEL_PARAMS= {
# ----------------------------------------Redis 集群模式-------------------------------------

# Redis 集群地址
REDIS_MASTER_NODES = [
REDIS_STARTUP_NODES = [
{"host": "172.25.2.25", "port": "6379"},
{"host": "172.25.2.26", "port": "6379"},
{"host": "172.25.2.27", "port": "6379"},
Expand Down
2 changes: 1 addition & 1 deletion README.rst
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ scrapy-redis 集群版
# ----------------------------------------Redis 集群模式-------------------------------------
# Redis 集群地址
REDIS_MASTER_NODES = [
REDIS_STARTUP_NODES = [
{"host": "172.25.2.25", "port": "6379"},
{"host": "172.25.2.26", "port": "6379"},
{"host": "172.25.2.27", "port": "6379"},
Expand Down
4 changes: 2 additions & 2 deletions scrapy_redis_sentinel/connection.py
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ def get_redis_cluster_from_settings(settings):
"""
params = defaults.REDIS_PARAMS.copy()
params.update(settings.getdict("REDIS_CLUSTER_PARAMS"))
params.setdefault("startup_nodes", settings.get("REDIS_MASTER_NODES"))
params.setdefault("startup_nodes", settings.get("REDIS_STARTUP_NODES"))
# XXX: Deprecate REDIS_* settings.
for source, dest in REDIS_CLUSTER_SETTINGS_PARAMS_MAP.items():
val = settings.get(source)
Expand Down Expand Up @@ -172,6 +172,6 @@ def from_settings(settings):
"""
if "REDIS_SENTINELS" in settings:
return get_redis_sentinel_from_settings(settings)
elif "REDIS_MASTER_NODES" in settings or "REDIS_CLUSTER_URL" in settings:
elif "REDIS_STARTUP_NODES" in settings or "REDIS_CLUSTER_URL" in settings:
return get_redis_cluster_from_settings(settings)
return get_redis_from_settings(settings)
2 changes: 1 addition & 1 deletion scrapy_redis_sentinel/scheduler.py
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ def from_settings(cls, settings):
kwargs["serializer"] = importlib.import_module(kwargs["serializer"])

server = connection.from_settings(settings)
if not settings.get("REDIS_MASTER_NODES", False):
if not settings.get("REDIS_STARTUP_NODES", False):
server.ping()

return cls(server=server, **kwargs)
Expand Down
2 changes: 1 addition & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
name='scrapy-redis-sentinel',
description="Redis Cluster for Scrapy.",
long_description=open('README.rst', encoding="utf-8").read(),
version="0.2.2",
version="0.2.3",
author="Shi Tao",
author_email='shitao0418@gmail.com',
url='https://github.com/crawlmap/scrapy-redis-sentinel.git',
Expand Down

0 comments on commit 388cdd0

Please sign in to comment.