Kubernetes Resource監控怎么實現

本篇內容介紹了“Kubernetes Resource監控怎么實現”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

WATCH請求剖析

從Python使用Kubernetes API，如果使用Request庫的話，就十分輕松。API運行得十分好，總是使用并且返回JSON消息。但是發行watch請求就變得復雜多了。發一個watch請求理論上有兩種方法：一個是用流傳輸結果的普通HTTP請求，同時使用分塊編碼；另一種方法是使用websockets。不幸的是，當測試Kubernetes1.1 master的時候，并沒有正確地使用websocket協議，所以使用流傳輸結果才是正確的方法。

當使用分塊編碼流傳輸的時候，Kubernetes master會通過發送分塊的尺寸開始傳輸分塊。但是它不會發送一整個分塊，它只會發送一行文本，再被一行新的文本終止。這行文本是JSON編碼對象，里面還有event以及修改過的resource項目。所以協議是基于行的，而分塊編碼只是當結果可得的時候一個用來分流這些結果的方法。從表面上看用請求來做這個似乎不那么難：

然而iter_lines方法并沒有按照你想要的方向來做，它保有一個外部緩沖，這個緩沖意味著你永遠都看不到最后一個event因為你還在等著填滿那個緩沖。

這個問題的提出意味著通過實施你自己的iter_lines()函數來使用原套socket，從回應socket到讀取socket。很不幸，那個簡單的方法犯了一些錯誤。首先，它沒有正確地處理分塊編碼，描述分塊大小的八位元數會出現在輸出過程。但是更加重要的是，另一個緩沖層次正在繼續，一個你不能進行應急操作的緩沖層次。額外的緩沖是因為請求使用的是原始套接字的生成文件方法從中讀取數據。這對于Requests來說就講得通了，Python標準庫和OS都擅長通過緩沖加速。然而這并不意味著在Requests解析了響應的標頭后，緩沖就已經不知道使用了響應本身多大的字節，而且這些字節無法檢索。所以使用Requests來使用watch API基本上不太可能。

手動進行HTTP

所以如何從Python使用watch API？通過自己發出請求和處理響應。這個做起來其實很簡單，socket編程其實沒那么嚇人。首先，你需要連接socket到服務器，然后發送HTTP request。HTTP非常簡單，你只需要在socket上發送一些標頭即可：

注意，Host標頭被Kubernetes master要求用來接受request。

解析HTTP響應稍微有點復雜。然而http－parser庫實施HTTP解析方面的東西的時候，沒有涉及到sockets或者任何類似于網絡的東西。所以我們可以輕松地讀取和解析響應：

現在我們來響應已經被解析的標頭。很可能，一些本體數據已經接收到了，這很棒，這些本體數據在解析器中仍處于緩沖好的的狀態，直到我們檢索它。但是首先讓我們來保持讀取數據，直到沒有剩下的為止(不要在生產過程中這么做，對你的存儲系統不好)。

上圖展示了如何使用select在數據可得的時候只讀數據，而不是先阻斷，然后使數據再次可讀。當然，一旦使用了所有的數據，Kubernetes master 可能就會發送下一版本更新到PodList，但是讓我們現在先來讀一下接收到的events：

就是它！如果數據接收截至在換行符，然后lines.split() 調用會回到一個空的字符串（b''）作為最后一個項目。如果數據沒有在一個新的換行符那里結束，那么一個未完成的event會被接收，這樣當我們獲得其它數據的時候我們就需要保存下來。

“Kubernetes Resource監控怎么實現”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！