【kubernetes】使用luakube访问kubernetes api

文章目录

      • 1 kubernetes client
      • 2 luakube初体验
      • 3 luakube代码分析
      • 4 luakube包的调用
      • 5 lua相关
        • 5.1 self
        • 5.2 metatable
          • 5.2.1 使用metatable对table新增操作符
          • 5.2.2 使用metatable对table新增方法
          • 5.2.3 再探luakube
      • 6 参考文档

1 kubernetes client

客户端列出了各种语言对应的访问k8s的客户端库,有官方维护的,还有一些是社区和个人维护的。

这里面没有列出lua的库,在GitHub上搜索可以看到有luakube,虽然好像没啥star,而且4个多月没更新了,可以用它进行测试下,如果基础的连接k8s的部分完成了,后面的各种资源操作可以自行开发和添加。当然,了解kubernetes api的都知道,这些api库基本就是对http api的调用封装,因此,luakube也是对http api的封装,它的优点在于,使用体验跟k8s的golang库的api类似,也就是拥有类k8s的调用方式。

2 luakube初体验

要使用luakube,第一步当然是环境安装,然后执行其中的示例代码。

luakube是个lua中的包,使用luarocks进行管理,因此,先安装lua和luarocks,然后再安装luakube。

luakube的依赖:

  • lyaml:yaml文件的解析
  • luajson:json的解析
  • base64:解析token
  • luasec:https
  • luasocket:https依赖luasocket
  • fun:提供了一些iter、map等操作,可以改写
  • lpeg:luajson依赖lpeg

luarocks中每个包都有一个rockspec文件,该文件描述了该包的依赖以及一些安装信息。因此,安装luakube有两种方式:要么按照rockspec的提示一个依赖一个依赖的安装,要么直接使用rockspec文件安装:

安装方法1:

yum install -y libyaml-devel
luarocks install lyaml
yum install -y lua-lpeg
luarocks install luajson
luarocks install luasocket
yum install -y openssl-devel
luarocks install luasec
luarocks install base64
luarocks install fun
luarocks install luakube

安装方法2:

luarocks install https://raw.githubusercontent.com/f4z3r/luakube/master/rockspecs/luakube-0.1.0-0.rockspec

安装方法3:

git clone https://github.com/f4z3r/luakube.git
cd luakube && luarocks make

第1种方法和第2种方法都是将luakube作为模块安装,相当于直接下载源码然后拷贝到安装目录,第3种方式是直接用本地目录中的rockspec文件进行安装,将本地目录的源代码拷贝到安装目录。

因此,如果是需要对luakube进行修改,可以用第3种方式,在本地目录修改后执行luarocks make,然后再进行测试。

安装完luakube,可以执行简单的demo代码进行测试,在luakube仓库的examples目录中有获取pod的logs的测试代码get_logs.lua:

local config = require "kube.config"
local api = require "kube.api"-- Use local kube config to connect to cluster
local conf = config.from_kube_config()
local global_client = api.Client:new(conf)-- Get the Core V1 client
local client = global_client:corev1()-- Get the last three lines of logs from the coredns container as a string
local container_logs = client:pods("kube-system"):logs("coredns-558bd4d5db-xr5tj", {tailLines = 3, container = "coredns"})-- Get the logs over the last 10 seconds for all containers in the pod
local last_logs = client:pods("kube-system"):logs("coredns-558bd4d5db-xr5tj", {sinceSeconds = 10})

测试时需要修改上面的名称空间和pod名,就可以得到对应pod的日志。

3 luakube代码分析

luakube源代码分成3个部分:

  • config.lua:对kubeconfig文件进行操作,外部代码实际调用时通常是调用from_kube_config(如果参数指定了kubeconfig文件,则用该文件作为凭证,如果没有指定,则用默认的kubeconfig文件路径)和in_cluster_config(在k8s集群中运行时获取sa的token作为凭证)
  • api.lua:对https调用的封装
  • api/:对每个version对应的资源进行操作

下面从分析examples/get_logs.lua的角度看下luakube的具体实现。

local conf = config.from_kube_config()

首先获取到kubeconfig配置,如果没有提供文件名,则使用默认配置文件($HOME/.kube/config)。

local global_client = api.Client:new(conf)

根据上面得到的kubeconfig配置创建client,这里创建的就是api.lua中的api.Client。

local client = global_client:corev1()

调用api.lua中的api.Client:corev1()获取某个版本的api。

local container_logs = client:pods("kube-system"):logs("coredns-558bd4d5db-xr5tj", {tailLines = 3, container = "coredns"})

上面的代码是获取kube-system命名空间的coredns-558bd4d5db-xr5tj这个pod的coredns容器的后面3行日志。

调用client:pods就是调用core_v1.lua中的core_v1.Client.pods = utils.generate_object_client("pods", pod_base, true, true, true, extras),而utils.generate_object_client则是返回一个client,该client有各种操作资源的方法,同时还会将extras中指定的一些方法也放到该client中,对于core_v1.Client.pods,extras中有两个方法:logs和ephemeralcontainers,分别用于获取日志和临时容器。

当执行logs()时,就会调用extras中的logs方法,它会调用自身的raw_call()方法,而raw_call该方法就定义于api.lua中。

相当于调用的起点和终点都位于api.lua中。

在整体的实现中,用到了lua中的metadata编程,让返回的client拥有各种方法。

4 luakube包的调用

了解了上述实现的函数调用流程,在具体使用luakube包时,就可以按照k8s的设计调用相关的通用的函数。

例如,对于pod,可以使用client:pods(“kube-system”):list()获取kube-system命名空间的所有pod的列表,其他的如nodes、services、configmaps、secrets、serviceaccounts等都有类似的调用。

当前资源支持的操作有:

  • get(name, query):获取某个资源,可以给出资源名称
  • status(name):资源状态
  • create(obj, query):创建资源,提供创建资源的yaml
  • update(obj, query):更新资源
  • update_status(obj, query):更新资源状态
  • patch(name, patch, query, style):变更资源
  • path_status(name, patch, query, style):变更资源状态
  • delete(name, query):删除资源
  • delete_collection(body, query)
  • list(query):列出资源

其中:

  • name:资源名称
  • query:获取资源的条件,这个需要传table,然后会拼接到https请求的后面
  • obj:资源的yaml
  • patch:变更的字段
  • style
  • body

5 lua相关

5.1 self

self类似于c++/java中的this和python中的self,c++/java中的this由编译器自动处理,python中的self需要开发人员添加,而lua中的self还提供了语言级别的区分:

local t = {a = 1, b = 2}
function t:Add()return (self.a + self.b)
end
function t.Sub(self)return (self.a - self.b)
endprint(t.Add(t))
print(t:Sub())

如果用冒号定义和调用方法,lua解释器会自动添加self,如果用点号,则需要开发人员添加self。

5.2 metatable

metatable翻译为元表,可以理解为table的额外属性,当访问table的一些操作时,如果table不存在,可以由元表进行完成。

lua中的metatable的概念跟python中的保留方法很像:

python中对于双下划线开头和结尾的方法有特殊含义,例如,当创建一个对象时,就是调用类的__init__()方法,当用iter某个序列时,就是调用类的__iter__()方法,也就是说,当对对象调用某个方法时,会调用某个约定好的方法,如果开发人员没有定义则调用默认的方法,当然,默认方法必须要支持此类行为,例如,如果用iter遍历一个不能遍历的对象,如果没有定义__iter__()则会调用失败。

在lua中,除了常用的基本数据类型(nil、布尔、数字、字符串)之外,table是lua提供的唯一的的复合数据类型(其他数据类型都是针对特定场景),table可以用于实现数组、集合、字典、类等类型,而metatable就是在table上面附加的一种属性,也就是说,metatable只针对table类型。

跟python类似,在lua中,双下划线开头的方法有特殊含义,例如,当用+操作符对两个table相加时,就是调用第一个table的metatable中的__add()方法,这种相当于实现了对操作符的自定义,跟python中的__add__和C++中的operator +类似;当调用table一个不存在的方法时,就会调用table的metatable中的对应的方法,这种相当于实现了对类方法的动态增加。

要想使用metatable,有两个重要的方法:

  • setmetatable(table, metable):设置table的metatable,虽然这里是table,但是根据lua的文档可以知道,任何值都有metatable,但是只有table的metable可以在lua中通过setmtatable修改,其他类型只能通过C语言修改。如果metatable设置为nil,则删除table的metatable;如果table的metatable中有__metatable元素,则抛出异常,函数返回新的table
  • getmetatable(object):返回对象的metatable。如果object没有metatable,则返回nil;如果object的metatable有__metatable元素,则返回对应的值;如果object的metatable没有__metatable元素,则返回对象的metatable。

下面演示操作符的实现和方法的增加:

5.2.1 使用metatable对table新增操作符
mytable = setmetatable({ 1, 2, 3 }, {__add = function(mytable, newtable)return table.move(newtable, 1, #newtable, #mytable+1, mytable)end
})secondtable = {4,5,6}mytable = mytable + secondtablefor k,v in ipairs(mytable) doprint(k,v)
end

使用setmetatable对table增加__add方法,__add实现时使用了table的move方法将第二个table中的元素放到第一个table中。

5.2.2 使用metatable对table新增方法
local mytable = {1, 2, 3}setmetatable(mytable, {__index = function(mytable, key)return function(self, newtable)table.move(newtable, 1, #newtable, #self+1, self)return selfendend
})local secondtable = {4,5,6}mytable:plus(secondtable)for i=1,#mytable doprint(mytable[i])
end

这里是给table增加了plus方法,通过增加带__index的metatable实现,__index对应的是个函数,而且它返回的也是个函数,返回的这个函数完成的就是两个table拼接的操作。因此,当调用mytable:plus时,由于mytable没有plus对应的值,就会查找metatable中的__index元素,由于__index存在,则会调用,并传入mytable和调用的键,因此,这里key==plus,而__index返回的时个函数,也就是说,mytable:plus返回的是个函数,然后用里面的这层函数调用,newtable传入的就是secondtable。

5.2.3 再探luakube

luakube通过k8s的rest api访问,因此,只要知道调用接口的url和参数即可。

k8s的rest api的url格式如下:

http://[api/apis]/api-group/api-version/namespaces/namespace/resource-kind/resource-name

例如,获取命名空间default的所有pod:http://127.0.0.1:8001/api/v1/namespaces/default/pods

而k8s的rest api,其实就是完成资源操作的CRUD,只有在需要提供yaml文件时,才会把yaml文件放到body里面,其他的参数都放到url里面,因此,重点就是要对url进行拼接和调用。

luakube为了使得调用封装的调用更加灵活,将url中不同的部分放到不同的地方。

开始的api和apis在api.lua中,现在只有api/v1是api,其他都是apis。

api-group/api-version在utils.lua的utils.generate_base(api)中,其中参数api就是api-group/api-version,在下面client.call中会将self.api_拼接到路径前面进行调用。

剩下的部分则在utils.lua的utils.generate_object_client(api,concat,namespaced)中,其中参数api就是资源类型resource-kind,concat是yaml中的apiVersion和kind,对于需要yaml文件作为参数的需要,namespaced则是说明该资源是否可以指定namespace,当然,最终是否要加上namespace,还要基于是否提供namespace参数。而最后的resource-name则是通过utils.generate_object_client()中的调用方法提供。

为了将上述的调用串起来,代码中大量使用下面的操作:

self.__index = self
setmetatable(o, self)

上面的代码将self作为o的metatable中的__index元素,于是,当访问o中的元素没有时,就会访问self中的元素,这样能够实现类似继承的机制,同时也可以给o添加方法,让o去调用self的方法,相当于子类调用父类的方法。

因此,将上面的url串起来的方式就是,在utils.generate_object_client()里面创建client,然后将core_v1.Client当作parent参数作为client的metatable,而core_v1.Client是通过utils.generate_base()返回的函数创建的client,这里又通过类似的机制调用api.lua中的方法。

总结下,通过metatable实现类似继承的机制,然后通过继承关系拼接url,最终调用api.lua中的https接口实现k8s的api的访问。

6 参考文档

  • Lua中的self
  • Lua 元表(Metatable)
  • Lua 5.4 Reference Manual
  • k8s restful API 结构分析
  • 对lua继承中self.__index = self的释疑
  • Kubernetes API

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/93230.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

docker系列(9) - docker-compose

文章目录 9. compose编排9.1 介绍9.2 安装9.3 compose常用命令9.4 实战Springboot部署9.4.1 准备组件配置文件9.4.1.1 redis的配置文件9.4.1.2 MySQL的配置文件9.4.1.3 SpringBoot打包文件 9.4.2 准备docker-compose.yml9.4.3 启动服务9.4.4 测试验证 9.5 实战ElasticsearchKib…

SLAM从入门到精通(从amcl到navigation软件栈)

【 声明:版权所有,欢迎转载,请勿用于商业用途。 联系信箱:feixiaoxing 163.com】 前面我们学习了amcl,但它只是navigation里面的一个package而已。真正的导航还包含很多的内容。举个例子来讨论下,我们假设需…

windows C 开发

在win下用C/C开发 非图形界面 应用程序 基础环境包括3个内容1. API : 一般是系统(包括c标准库和其他dll)提供的2. 编译器 : 可以是gnu的,可以是微软提供的3. 编辑器 : 随意都可以 // 不再考虑范围开发方式(API编译器) 原生windows API 使用 Windows API 来编写非视窗代码。…

基于 QT 实现 Task Timer,高效利用时间

一、开发环境 Ubuntu 20.04 QT6.0 二、新建 Qt Wigets Application 这里的基类选择 Wigets, pro 配置文件添加 sql 模块,需要用到 sqlite, QT sql 三、添加数据库连接头文件 // connection.h #ifndef CONNECTION_H #define CONNECTION_…

Acwing 840. 模拟散列表

Acwing 840. 模拟散列表 题目描述思路讲解代码展示 题目描述 思路讲解 代码展示 拉链法&#xff1a; #include <cstring> #include <iostream>using namespace std;const int N 100003;int h[N], e[N], ne[N], idx;void insert(int x) {int k (x % N N) % N;e…

数据分析技能点-机器学习优化思想

优化思想,这个听起来极其专业和高端的词汇,其实它无处不在,悄无声息地影响着我们的生活和决策。从寻找最快的上班路线,到决定如何配置投资组合,优化思想都是一个不可或缺的元素。而在机器学习领域,优化思想更是扮演着至关重要的角色。 文章目录 优化的基础优化问题与实际…

历史服务器

二、配置历史服务器 在spark-3.1.1-bin-hadoop2.7/conf/spark-defaults.conf添加以下配置&#xff0c;其中d:/log/spark为日志保存位置 spark.eventLog.enabled true spark.eventLog.dir file:///d:/log/spark spark.eventLog.compress true spark.history.fs.logDirectory fil…

图神经网络GNN(一)GraphEmbedding

DeepWalk 使用随机游走采样得到每个结点x的上下文信息&#xff0c;记作Context(x)。 SkipGram优化的目标函数&#xff1a;P(Context(x)|x;θ) θ argmax P(Context(x)|x;θ) DeepWalk这种GraphEmbedding方法是一种无监督方法&#xff0c;个人理解有点类似生成模型的Encoder过程…

8.3Jmeter使用json提取器提取数组值并循环(循环控制器)遍历使用

Jmeter使用json提取器提取数组值并循环遍历使用 响应返回值例如&#xff1a; {"code":0,"data":{"totalCount":11,"pageSize":100,"totalPage":1,"currPage":1,"list":[{"structuredId":&q…

字符串,字符数组,类型转换,整数越界,浮点数,枚举

目录 自动类型转换 强制类型转换 数据类型 sizeof 数据类型所占字节数 整数越界 浮点数 字符型 字符串变量 ​编辑字符串的输入输出 main函数的参数 &#xff0c;argc,argv 单个字符输入输出 putchar getchar strlen,strcmp,strcat,strchr,strstr strlen 求字…

云安全之HTTP协议介绍补充

HTTP是一个基于TCP/IP通信协议来传递数据的协议&#xff0c;传输的数据类型为HTML文件、图片文件、查询结果等。HTTP协议一般用于B/S架构。浏览器作为HTTP客户端通过URL向HTTP服务端即WEB服务器发送所有请求。 URI、URL、URN HTTP使用统一资源标识符(Uniform Resource ldentif…

【Rust日报】2023-09-30 使用Rust做web抓取

CockroachDB 用rust重新实现 嘿&#xff0c;伙计们&#xff0c;我在 Rust 中实现了一个分布式 SQL 数据库。它就像 CockroachDB 和谷歌Google Spanner。告诉我你的想法。 注意: 这不是生产级别的数据库&#xff0c;这是一个以学习为目的的项目。有许多特性&#xff0c;但是缺少…

【软件工程_UML—StartUML作图工具】startUML怎么画interface接口

StartUML作图工具怎么画interface接口 初试为圆形 &#xff0c;点击该接口在右下角的设置中->Format->Stereotype Display->Label&#xff0c;即可切换到想要的样式 其他方式 在class diagram下&#xff0c;左侧有interface图标&#xff0c;先鼠标左键选择&#xff0…

Google vs IBM vs Microsoft: 哪个在线数据分析师证书最好

Google vs IBM vs Microsoft: 哪个在线数据分析师证书最好&#xff1f; 对目前市场上前三个数据分析师证书进行审查和比较|Madison Hunter 似乎每个重要的公司都推出了自己版本的同一事物&#xff1a;专业数据分析师认证&#xff0c;旨在使您成为雇主的下一个热门商品。 随着…

警告-Ubuntu提示W: Possible missing firmware xxx解决方法

目录 现象原因解决方法 现象 当执行 sudo apt-get update或者sudo apt-get dist-upgrade时&#xff0c;有如下警告&#xff1a; W: Possible missing firmware /lib/firmware/rtl_nic/rtl8125a-3.fw for module r8169 W: Possible missing firmware /lib/firmware/rtl_nic/rt…

侯捷 C++ STL标准库和泛型编程 —— 4 分配器 + 5 迭代器

4 分配器 4.1 测试 分配器都是与容器共同使用的&#xff0c;一般分配器参数用默认值即可 list<string, allocator<string>> c1;不建议直接用分配器分配空间&#xff0c;因为其需要在释放内存时也要指明大小 int* p; p allocator<int>().allocate(512,…

Emmet语法

CSS复合选择器 接上边的父选择器 子选择器只会选择最近的后代&#xff0c;进行变色 元素1和元素2中间用大于号隔开 元素1是父级&#xff0c;元素2是子级&#xff0c;选子级 ol>li{ color: red&#xff1b;} 并集选择器 不同类型的标签如&#xff1a;div p ul span &l…

nodejs+vue交通违章查询及缴费elementui

第三章 系统分析 10 3.1需求分析 10 3.2可行性分析 10 3.2.1技术可行性&#xff1a;技术背景 10 3.2.2经济可行性 11 3.2.3操作可行性&#xff1a; 11 3.3性能分析 11 3.4系统操作流程 12 3.4.1管理员登录流程 12 3.4.2信息添加流程 12 3.4.3信息删除流程 13 第四章 系统设计与…

【STM32】IAP升级03关闭总中断,检测栈顶指针

IAP升级方法 IAP升级时需要关闭总中断 TM32在使用时有时需要禁用全局中断&#xff0c;比如MCU在升级过程中需禁用外部中断&#xff0c;防止升级过程中外部中断触发导致升级失败。 ARM MDK中提供了如下两个接口来禁用和开启总中断&#xff1a; __disable_irq(); // 关闭总中…

8. 基于消影点进行相机内参(主点)的标定

目录 1. ocam模型2. 消影点3. 基于消影点进行相机主点标定3.1 基于ocam模型的主点标定 感谢大家的阅读。 1. ocam模型 可以参考我的另一篇博客ocam模型。 这里简单提一下ocam模型&#xff1a; 这个模型将中心折反射相机和鱼眼相机统一在一个通用模型下&#xff0c;也称为泰勒模…