ssh tunnel 什么时候可以支持mongodb

[xiaoshumiao6]

1. 使用ssh 隧道连接mongodb 一直都是失败的； 查看代码发现如下内容：

判断如果配置了隧道则连接隧道，只测试了MySQL

        if self.instance.tunnel:
            self.ssh = SSHConnection(

[LeoQuote]

你好, 本项目是一个开源项目, 你可以自由提功能需求, 但其实比提功能需求更加务实, 有价值的是实现这个功能, 本项目开发文档如下, 希望对你有帮助:

• https://github.com/hhyo/Archery/wiki/development
• https://github.com/hhyo/Archery/wiki/notifier

期待你的pr, 谢谢~

[xiaoshumiao6]

遇到了一个诡异的问题 ：辛苦大佬看一下；

还是上面的问题， mongodb 配置使用「连接隧道」， 然后进行在线查询， 会报错， 详情如下：

1. 点击「在线查询」，选择实例后， 继续选择数据库， 数据库一直加载不出来， 报错504 ；
2. 对「sql/instance.py」 文件添加额外的日志：

344         elif resource_type == "column" and db_name and tb_name:
345             resource = query_engine.get_all_columns_by_tb(
346                 db_name=db_name, tb_name=tb_name, schema_name=schema_name
347             )
348         else:
349             raise TypeError("不支持的资源类型或者参数不完整！")
350     #logger.error("instance_resource2")
351     except Exception as msg:
352         result["status"] = 1
353         result["msg"] = str(msg)
354     else:
355         if resource.error:
356             result["status"] = 1
357             result["msg"] = resource.error
358         else:
359             result["data"] = resource.rows
360     print(result)
361     print("1111#Hello, World!1")
362     print(HttpResponse(json.dumps(result), content_type="application/json"))
363     return HttpResponse(json.dumps(result), content_type="application/json")

3. 日志详情

{'status': 0, 'msg': 'ok', 'data': ['lockin_saastoc']}
1111#Hello, World!1
<HttpResponse status_code=200, "application/json">

但是就是不会执行return HttpResponse 返回http 请求， nginx 代理60S 超时后， 直接504

4. 同样的请求("instance/instance_resource/")， 如果数据库类型为mysql , 就能够得到正常的http 请求， 日志打印如下：

show databases
{'status': 0, 'msg': 'ok', 'data': ['lockin_saastoc']}
1111#Hello, World!1
<HttpResponse status_code=200, "application/json">
[22/Mar/2024 23:41:29] "GET /instance/instance_resource/?instance_name=prod_lockin_saastoc_mysql_3306_lockin_saastoc&resource_type=database HTTP/1.0" 200 54

[LeoQuote]

这块我不是很了解，不好意思，你试试开一下debug 追踪下

[xiaoshumiao6]

找到原因了， 由于开启的ssh 隧道一直没有关闭， 所以请求一直没有返回， 修复代码：

sql/instance.py

        else:
            raise TypeError("不支持的资源类型或者参数不完整！")
    except Exception as msg:
        result["status"] = 1
        result["msg"] = str(msg)
    else:
        if instance.tunnel:
            query_engine.close()
            query_engine.ssh.server.close()
            del query_engine.ssh
        if resource.error:
            result["status"] = 1
            result["msg"] = resource.error
        else:
            result["data"] = resource.rows