1、首先模擬python類似shell命令行操作的接口：

python安裝subprocess(本地)、paramiko(SSH遠(yuǎn)程)

#-*- coding: UTF-8 -*-

#!/usr/bin/python

import os, sys

import subprocess

import paramiko

import settings

class RunCmd(object):

def __init__(self):

self.cmd = 'ls'

@staticmethod

def local_run(cmd):

print('start executing...')

print('cmd is -------> %s' % str(cmd))

s = subprocess.Popen(str(cmd), shell=True, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE)

out, err = s.communicate()

print("outinfo is -------> %s" % out)

print("errinfo is -------> %s" % err)

print('finish executing...')

print('result:------> %s' % s.returncode)

return s.returncode

@staticmethod

def remote_run(host, username, password, port, cmd):

client = paramiko.SSHClient()

client.set_missing_host_key_policy(paramiko.AutoAddPolicy())

client.connect(hostname=host, port=int(port), username=username, password=password, timeout=5)

stdin, stdout, stderr = client.exec_command(cmd)

result = stdout.read()

client.close()

return result

@staticmethod

def krb_run(cmd):

print('krb_run start...')

print('cmd is -------> %s' % str(cmd))

result = RunCmd.remote_run(settings.KRB_HOST, settings.USERNAME, settings.PASSWORD, settings.PORT, cmd)

print('result:------> %s' % result)

print('krb_run finish...')

return result

2、Kerberos常用的命令操作封裝成接口，其他簡(jiǎn)單。但需要交互的是刪除 principal

def delete_user(self, username):

cmd = r"""

expect -c "

set timeout 1;

spawn kadmin.local -q \"delete_principal {principal}\" ;

expect yes/no {{ send \"yes\r\" }} ;

expect *\r

expect \r

expect eof

"

""".format(principal=username)

RunCmd.krb_run(cmd)

補(bǔ)充知識(shí)：python操作有Kerberos認(rèn)證的hive庫(kù)

之前訪問hive都比較簡(jiǎn)單，直接用pyhive連接即可。

但是最近遇到了一個(gè)問題，hive有了Kerberosren認(rèn)證。

最終經(jīng)過各種嘗試和靈感迸發(fā)，終于解決了這個(gè)問題，遂記錄之。

代碼

from pyhive.hive import connect

con = connect(host='XXXX',port=10000,auth='KERBEROS',kerberos_service_name="hive")

cursor = con.cursor()

cursor.execute('select * from tmp.pricing_calculate_result_spark where time_id="201907171355" limit 10,1')

datas = cursor.fetchall()

print(datas)

cursor.close()

con.close()

端口和ip都換成自己的，auth和kerberos_service_name不要改

運(yùn)行效果

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。

總結(jié)

以上是生活随笔為你收集整理的python子进程kerberos_Python实现Kerberos用户的增删改查操作的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。