欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

python3.6.5基于kerberos認(rèn)證的hive和hdfs連接調(diào)用方式

 更新時間:2020年06月06日 10:12:35   作者:后廠村葫蘆娃  
這篇文章主要介紹了python3.6.5基于kerberos認(rèn)證的hive和hdfs連接調(diào)用方式,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧

1. Kerberos是一種計算機網(wǎng)絡(luò)授權(quán)協(xié)議,用來在非安全網(wǎng)絡(luò)中,對個人通信以安全的手段進行身份認(rèn)證。具體請查閱官網(wǎng)

2. 需要安裝的包(基于centos)

yum install libsasl2-dev
yum install gcc-c++ python-devel.x86_64 cyrus-sasl-devel.x86_64
yum install python-devel 
yum install krb5-devel
yum install python-krbV
 
pip install krbcontext==0.9
pip install thrift==0.9.3
pip install thrift-sasl==0.2.1
pip install impyla==0.14.1
pip install hdfs[kerberos]
pip install pykerberos==1.2.1

3. /etc/krb5.conf 配置, 在這個文件里配置你服務(wù)器所在的域

4./etc/hosts 配置, 配置集群機器和域所在機器

5. 通過kinit 生成 ccache_file或者keytab_file

6. 連接hive代碼如下

import os
from impala.dbapi import connect
from krbcontext import krbcontext
keytab_path = os.path.split(os.path.realpath(__file__))[0] + '/xxx.keytab'
principal = 'xxx'
with krbcontext(using_keytab=True,principal=principal,keytab_file=keytab_path):
 conn = connect(host=ip, port=10000, auth_mechanism='GSSAPI', kerberos_service_name='hive')
 cursor = conn.cursor()
 cursor.execute('SELECT * FROM default.books')
 for row in cursor:
  print(row)

7. 連接hdfs代碼如下

from hdfs.ext.kerberos import KerberosClient
from krbcontext import krbcontext
 
hdfs_url = 'http://' + host + ':' + port
data = self._get_keytab(sso_ticket)
self._save_keytab(data)
with krbcontext(using_keytab=True, keytab_file=self.keytab_file, principal=self.user):
 self.client = KerberosClient(hdfs_url)
 self.client._list_status(path).json()['FileStatuses']['FileStatus'] #獲取path下文件及文件夾

8. 注:krbcontext這個包官方說支持python2,但是python3也能用

這個hdfs_url 一定要帶"http://"不然會報錯

9. 我新增了一些配置文件配置,具體的操作如下

python3.6.5基于kerberos認(rèn)證的hdfs,hive連接調(diào)用(含基礎(chǔ)環(huán)境配置)

1需要準(zhǔn)備的環(huán)境

yum包(需要先裝yum包,再裝python包,不然會有問題)

 yum install openldap-clients -y
 yum install krb5-workstation krb5-libs -y
 yum install gcc-c++ python-devel.x86_64 cyrus-sasl-devel.x86_64
 yum install python-devel 
 yum install krb5-devel
 yum install python-krbV
 yum install cyrus-sasl-plain cyrus-sasl-devel cyrus-sasl-gssapi

python包安裝(pip或pip3,請根據(jù)實際情況選擇)

 pip install krbcontext==0.9
 pip install thrift==0.9.3
 pip install thrift-sasl==0.2.1
 pip install impyla==0.14.1
 pip install hdfs[kerberos]
 pip install pykerberos==1.2.1

配置/etc/hosts文件(需要把大數(shù)據(jù)平臺的機器和域名進行配置)

10.xxx.xxx.xxx name-1 panel.test.com
10.xxx.xxx.xxx name-1

配置/etc/krb5.conf(具體查看kerberos服務(wù)配置中心)

參考配置(僅供參考,具體更具自己實際配置修改)

[libdefaults]
  renew_lifetime = 9d
  forwardable = true
  default_realm = PANEL.COM
  ticket_lifetime = 24h
  dns_lookup_realm = false
  dns_lookup_kdc = false
  default_ccache_name = /tmp/krb5cc_%{uid}
 [logging]
  default = FILE:/var/log/krb5kdc.log
  admin_server = FILE:/var/log/kadmind1.log
  kdc = FILE:/var/log/krb5kdc1.log
 [realms]
  PANEL.COM = {
  admin_server = panel.test1.com
  kdc = panel.test1.com
  }

連接代碼:

hdfs:

import json, os
from hdfs.ext.kerberos import KerberosClient
from krbcontext import krbcontext
 
 def _connect(self, host, port, sso_ticket=None):
  try:
   hdfs_url = 'http://' + host + ':' + port
   active_str = 'kinit -kt {0} {1}'.format(self.keytab_file, self.user)
   # 激活當(dāng)前kerberos用戶認(rèn)證,因為python緩存機制,切換用戶,這個緩存不會自動切換,需要手動處理下
   os.system(active_str)
   with krbcontext(using_keytab=True, keytab_file=self.keytab_file, principal=self.user):
    self.client = KerberosClient(hdfs_url)
  except Exception as e:
   raise e

hive

import os
from krbcontext import krbcontext
from impala.dbapi import connect
from auto_model_platform.settings import config

 def _connect(self, host, port, sso_ticket=None):
  try:
   active_str = 'kinit -kt {0} {1}'.format(self.keytab_file, self.user)
   # 同hdfs
   os.system(active_str)
   with krbcontext(using_keytab=True, principal=self.user, keytab_file=self.keytab_file):
    self.conn = connect(host=host, port=port, auth_mechanism='GSSAPI', kerberos_service_name='hive')
    self.cursor = self.conn.cursor()
  except Exception as e:
   raise e

總結(jié)

我在做的時候也遇到很多坑,其實在這個需要理解其中原理,比如kerberos的機制和對應(yīng)命令

如果是做基礎(chǔ)平臺用,用多用戶切換的情況,建議不要用python,因為一點都不友好,官方包問題很多,我都改用java的jdbc去操作hdfs和hive了

如果只是自己測試和和做算法研究,還是可以用的,因為這個代碼簡單,容易實現(xiàn)

補充

kinit命令

kinit -kt xxxx.keytab #激活xxxx用戶當(dāng)前緩存
kinit list #查看當(dāng)前緩存用戶

以上這篇python3.6.5基于kerberos認(rèn)證的hive和hdfs連接調(diào)用方式就是小編分享給大家的全部內(nèi)容了,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • 在Linux下使用命令行安裝Python

    在Linux下使用命令行安裝Python

    這篇文章主要介紹了在Linux下使用命令行安裝Python,通過詳細(xì)的圖文介紹Linux安裝Python的全部過程,希望對你有所幫助
    2021-06-06
  • python K近鄰算法的kd樹實現(xiàn)

    python K近鄰算法的kd樹實現(xiàn)

    這篇文章主要介紹了python K近鄰算法的kd樹實現(xiàn),小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-09-09
  • Python閉眼時長標(biāo)準(zhǔn)差腳本使用實例代碼講解

    Python閉眼時長標(biāo)準(zhǔn)差腳本使用實例代碼講解

    這篇文章主要介紹了Python閉眼時長標(biāo)準(zhǔn)差腳本使用,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)吧
    2023-03-03
  • 利用python寫個下載teahour音頻的小腳本

    利用python寫個下載teahour音頻的小腳本

    這篇文章主要跟大家分享了一個利用python寫的下載teahour音頻的小腳本,文中給出了詳細(xì)的示例代碼供大家參考學(xué)習(xí),對大家具有一定的參考價值,需要的朋友們下面來一起看看吧。
    2017-05-05
  • 極速整理文件Python自動化辦公實用技巧

    極速整理文件Python自動化辦公實用技巧

    當(dāng)涉及到自動化辦公和文件整理,Python確實是一個強大的工具,在這篇博客文章中,將深入探討極速整理文件!Python自動化辦公新利器這個話題,并提供更加豐富和全面的示例代碼,以便讀者更好地理解和運用這些技巧
    2024-01-01
  • Matplotlib配色之Colormap詳解

    Matplotlib配色之Colormap詳解

    這篇文章主要介紹了Matplotlib配色之Colormap詳解,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2021-01-01
  • python 調(diào)用win32pai 操作cmd的方法

    python 調(diào)用win32pai 操作cmd的方法

    下面小編就為大家?guī)硪黄猵ython 調(diào)用win32pai 操作cmd的方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-05-05
  • 基于django2.2連oracle11g解決版本沖突的問題

    基于django2.2連oracle11g解決版本沖突的問題

    這篇文章主要介紹了基于django2.2連oracle11g解決版本沖突的問題,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-07-07
  • Python繪制柱狀圖可視化神器pyecharts

    Python繪制柱狀圖可視化神器pyecharts

    這篇文章主要介紹了Python繪制柱狀圖可視化神器pyecharts,文章圍繞主題展開詳細(xì)的內(nèi)容介紹,具有一定的參考價值,需要的小伙伴可以參考一下
    2022-09-09
  • python3.4用函數(shù)操作mysql5.7數(shù)據(jù)庫

    python3.4用函數(shù)操作mysql5.7數(shù)據(jù)庫

    這篇文章主要為大家詳細(xì)介紹了python3.4用函數(shù)操作mysql5.7數(shù)據(jù)庫,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-06-06

最新評論