擅长:python、mysql、java
<p>我缺少的是<code>request.get</code>参数中的<code>stream=True</code>,该参数允许迭代响应内容,因此我的代码如下所示:</p>
<pre><code>import requests
class Logs():
def __init__(self, url='https://192.168.0.1:6443/api/v1/',
cert='./client.crt',
key='./client.key'):
self.url = url
self.cert = cert
self.key = key
requests.packages.urllib3.disable_warnings()
def get_pod_logs(self, namespace, pod_name):
params = dict(
follow="true",
tailLines="100"
)
r = requests.get(self.url + "namespaces/" + namespace + "/pods/" + pod_name + "/log", params=params,
cert=(self.cert, self.key), verify=False, stream=True)
for chunk in r.iter_content(chunk_size=256):
if chunk:
print(chunk)
logs = Logs()
logs.get_pod_logs(namespace="my-ns",pod_name="my-pod")
</code></pre>