PS： 最近在重構(gòu)公司的業(yè)務(wù)容器化平臺(tái)，記錄一塊。關(guān)于容器日志的， kubernetes python API本身提供了日志流式數(shù)據(jù)，在以前的版本是不會(huì)輸出新數(shù)據(jù)的，后續(xù)版本進(jìn)行了改進(jìn)。

創(chuàng)新互聯(lián)公司是一家集網(wǎng)站建設(shè),鼓樓企業(yè)網(wǎng)站建設(shè),鼓樓品牌網(wǎng)站建設(shè),網(wǎng)站定制,鼓樓網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷(xiāo),網(wǎng)絡(luò)優(yōu)化,鼓樓網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力?？沙浞譂M(mǎn)足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專(zhuān)業(yè)、時(shí)尚、前沿，時(shí)刻以成就客戶(hù)成長(zhǎng)自我，堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。

直接上代碼

Flask 前端路由塊

# Router
"""獲取項(xiàng)目pod的日志"""
@api_cluster_pod.route('///pod//log')
@env_rules
def api_cluster_pod_log(env, cluster_name, pod_name):
    """查看pod的log"""

    tail_lines = request.values.get("tail_lines", 1000)
    namespace = request.values.get("namespace", "")

    # 生成Config Object
    try:
        cluster_config = ClusterConfig(
            env=env,
            cluster_name=cluster_name,
            namespace=namespace
        )
    except Exception as e:
        return jsonify(dict(
            code=5000,
            message='獲取集群接口時(shí)未找到對(duì)應(yīng)條目, 信息：{0}'.format(str(e))
        ))

    try:
        poder = Pod( cluster_config)
        resp = Response(stream_with_context(poder.get_pod_log(pod_name, tail_lines)), mimetype="text/plain")
        return resp

    except Exception as e:
        return jsonify(dict(
            code=7000,
            message=str(e)
        ))

Flask 后端代碼塊

# 后臺(tái)功能
class Pod:
    ...
       def get_pod_log(self, pod_name, tail_lines=100):
        """
        獲取pod的日志
        :param tail_lines: # 顯示最后多少行
        :return:
        """
        try:
            # stream pod log
            streams = self.cluster.api.read_namespaced_pod_log(
                pod_name,
                self.cluster_config.namespace,
                follow=True,
                _preload_content=False,
                tail_lines=tail_lines).stream()
            return streams

        except ApiException as e:
            if e.status == 404:
                logger.exception("Get Log not fund Podname: {0}".format(pod_name))
                raise PodNotFund("獲取日志時(shí)，未找到此pod: {0}".format(pod_name))
            if e.status == 400:
                raise PodNotFund("容器并未創(chuàng)建成功，請(qǐng)聯(lián)系運(yùn)維人員進(jìn)行排查。")
            raise e
        except Exception as e:
            logger.exception("Get Log Fail: {0}".format(str(e)))
            raise e

HTML

其它

我們應(yīng)用是前后端分離的，把html里面的核心代碼放置VUE里面就可以了。

效果圖

日志是流式的，如果Container有日志，則窗口會(huì)運(yùn)態(tài)更新。