1.get_connection() 方法的 command_name 参数已经被弃用,更新使用调用get_connection() 方法
2.更新清华导入库测试账号密码
7 files added
5 files modified
2 files deleted
| New file |
| | |
| | | # 默认忽略的文件 |
| | | /shelf/ |
| | | /workspace.xml |
| | | # 基于编辑器的 HTTP 客户端请求 |
| | | /httpRequests/ |
| | | # Datasource local storage ignored files |
| | | /dataSources/ |
| | | /dataSources.local.xml |
| New file |
| | |
| | | <component name="InspectionProjectProfileManager"> |
| | | <profile version="1.0"> |
| | | <option name="myName" value="Project Default" /> |
| | | <inspection_tool class="Eslint" enabled="true" level="WARNING" enabled_by_default="true" /> |
| | | </profile> |
| | | </component> |
| New file |
| | |
| | | <component name="InspectionProjectProfileManager"> |
| | | <settings> |
| | | <option name="USE_PROJECT_PROFILE" value="false" /> |
| | | <version value="1.0" /> |
| | | </settings> |
| | | </component> |
| New file |
| | |
| | | <?xml version="1.0" encoding="UTF-8"?> |
| | | <project version="4"> |
| | | <component name="ProjectModuleManager"> |
| | | <modules> |
| | | <module fileurl="file://$PROJECT_DIR$/.idea/脚本.iml" filepath="$PROJECT_DIR$/.idea/脚本.iml" /> |
| | | </modules> |
| | | </component> |
| | | </project> |
| New file |
| | |
| | | <?xml version="1.0" encoding="UTF-8"?> |
| | | <project version="4"> |
| | | <component name="VcsDirectoryMappings"> |
| | | <mapping directory="$PROJECT_DIR$/../.." vcs="Git" /> |
| | | <mapping directory="$PROJECT_DIR$/造数脚本" vcs="Git" /> |
| | | </component> |
| | | </project> |
| New file |
| | |
| | | <?xml version="1.0" encoding="UTF-8"?> |
| | | <module type="PYTHON_MODULE" version="4"> |
| | | <component name="NewModuleRootManager"> |
| | | <content url="file://$MODULE_DIR$" /> |
| | | <orderEntry type="inheritedJdk" /> |
| | | <orderEntry type="sourceFolder" forTests="false" /> |
| | | </component> |
| | | </module> |
| | |
| | | for db_index in range(db_count): |
| | | try: |
| | | # 切换到指定数据库 |
| | | temp_client = self.redis_client.connection_pool.get_connection('ping') |
| | | temp_client = self.redis_client.connection_pool.get_connection() |
| | | temp_client.send_command('SELECT', db_index) |
| | | temp_client.read_response() |
| | | |
| | |
| | | for db_index in range(db_count): |
| | | try: |
| | | # 切换到指定数据库 |
| | | temp_client = self.redis_client.connection_pool.get_connection('ping') |
| | | temp_client = self.redis_client.connection_pool.get_connection() |
| | | temp_client.send_command('SELECT', db_index) |
| | | temp_client.read_response() |
| | | |
| | |
| | | for db_index in range(db_count): |
| | | try: |
| | | # 切换到指定数据库 |
| | | temp_client = self.redis_client.connection_pool.get_connection('ping') |
| | | temp_client = self.redis_client.connection_pool.get_connection() |
| | | temp_client.send_command('SELECT', db_index) |
| | | temp_client.read_response() |
| | | |
| | |
| | | for db_index in range(db_count): |
| | | try: |
| | | # 切换到指定数据库 |
| | | temp_client = self.redis_client.connection_pool.get_connection('ping') |
| | | temp_client = self.redis_client.connection_pool.get_connection() |
| | | await asyncio.to_thread(temp_client.send_command, 'SELECT', db_index) |
| | | await asyncio.to_thread(temp_client.read_response) |
| | | |