|
@@ -158,6 +158,7 @@ else:
|
|
|
# *********************** RANGER PLUGIN CHANGES ***********************
|
|
|
# ranger host
|
|
|
# **********************************************************************
|
|
|
+stack_supports_ranger_audit_db = stack_version_formatted and check_stack_feature(StackFeature.RANGER_AUDIT_DB_SUPPORT, stack_version_formatted)
|
|
|
ranger_admin_hosts = default("/clusterHostInfo/ranger_admin_hosts", [])
|
|
|
has_ranger_admin = not len(ranger_admin_hosts) == 0
|
|
|
xml_configurations_supported = config['configurations']['ranger-env']['xml_configurations_supported']
|
|
@@ -176,7 +177,7 @@ if has_ranger_admin and is_supported_kafka_ranger:
|
|
|
xa_audit_db_flavor = xa_audit_db_flavor.lower() if xa_audit_db_flavor else None
|
|
|
xa_audit_db_name = config['configurations']['admin-properties']['audit_db_name']
|
|
|
xa_audit_db_user = config['configurations']['admin-properties']['audit_db_user']
|
|
|
- xa_audit_db_password = unicode(config['configurations']['admin-properties']['audit_db_password'])
|
|
|
+ xa_audit_db_password = unicode(config['configurations']['admin-properties']['audit_db_password']) if stack_supports_ranger_audit_db else None
|
|
|
xa_db_host = config['configurations']['admin-properties']['db_host']
|
|
|
repo_name = str(config['clusterName']) + '_kafka'
|
|
|
|
|
@@ -211,38 +212,40 @@ if has_ranger_admin and is_supported_kafka_ranger:
|
|
|
#For curl command in ranger plugin to get db connector
|
|
|
jdk_location = config['hostLevelParams']['jdk_location']
|
|
|
java_share_dir = '/usr/share/java'
|
|
|
- if xa_audit_db_flavor and xa_audit_db_flavor == 'mysql':
|
|
|
- jdbc_jar_name = default("/hostLevelParams/custom_mysql_jdbc_name", None)
|
|
|
- audit_jdbc_url = format('jdbc:mysql://{xa_db_host}/{xa_audit_db_name}')
|
|
|
- jdbc_driver = "com.mysql.jdbc.Driver"
|
|
|
- elif xa_audit_db_flavor and xa_audit_db_flavor == 'oracle':
|
|
|
- jdbc_jar_name = default("/hostLevelParams/custom_oracle_jdbc_name", None)
|
|
|
- colon_count = xa_db_host.count(':')
|
|
|
- if colon_count == 2 or colon_count == 0:
|
|
|
- audit_jdbc_url = format('jdbc:oracle:thin:@{xa_db_host}')
|
|
|
- else:
|
|
|
- audit_jdbc_url = format('jdbc:oracle:thin:@//{xa_db_host}')
|
|
|
- jdbc_driver = "oracle.jdbc.OracleDriver"
|
|
|
- elif xa_audit_db_flavor and xa_audit_db_flavor == 'postgres':
|
|
|
- jdbc_jar_name = default("/hostLevelParams/custom_postgres_jdbc_name", None)
|
|
|
- audit_jdbc_url = format('jdbc:postgresql://{xa_db_host}/{xa_audit_db_name}')
|
|
|
- jdbc_driver = "org.postgresql.Driver"
|
|
|
- elif xa_audit_db_flavor and xa_audit_db_flavor == 'mssql':
|
|
|
- jdbc_jar_name = default("/hostLevelParams/custom_mssql_jdbc_name", None)
|
|
|
- audit_jdbc_url = format('jdbc:sqlserver://{xa_db_host};databaseName={xa_audit_db_name}')
|
|
|
- jdbc_driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
|
|
|
- elif xa_audit_db_flavor and xa_audit_db_flavor == 'sqla':
|
|
|
- jdbc_jar_name = default("/hostLevelParams/custom_sqlanywhere_jdbc_name", None)
|
|
|
- audit_jdbc_url = format('jdbc:sqlanywhere:database={xa_audit_db_name};host={xa_db_host}')
|
|
|
- jdbc_driver = "sap.jdbc4.sqlanywhere.IDriver"
|
|
|
-
|
|
|
- downloaded_custom_connector = format("{tmp_dir}/{jdbc_jar_name}")
|
|
|
-
|
|
|
- driver_curl_source = format("{jdk_location}/{jdbc_jar_name}")
|
|
|
- driver_curl_target = format("{kafka_home}/libs/{jdbc_jar_name}")
|
|
|
-
|
|
|
+ if stack_supports_ranger_audit_db:
|
|
|
+ if xa_audit_db_flavor and xa_audit_db_flavor == 'mysql':
|
|
|
+ jdbc_jar_name = default("/hostLevelParams/custom_mysql_jdbc_name", None)
|
|
|
+ audit_jdbc_url = format('jdbc:mysql://{xa_db_host}/{xa_audit_db_name}')
|
|
|
+ jdbc_driver = "com.mysql.jdbc.Driver"
|
|
|
+ elif xa_audit_db_flavor and xa_audit_db_flavor == 'oracle':
|
|
|
+ jdbc_jar_name = default("/hostLevelParams/custom_oracle_jdbc_name", None)
|
|
|
+ colon_count = xa_db_host.count(':')
|
|
|
+ if colon_count == 2 or colon_count == 0:
|
|
|
+ audit_jdbc_url = format('jdbc:oracle:thin:@{xa_db_host}')
|
|
|
+ else:
|
|
|
+ audit_jdbc_url = format('jdbc:oracle:thin:@//{xa_db_host}')
|
|
|
+ jdbc_driver = "oracle.jdbc.OracleDriver"
|
|
|
+ elif xa_audit_db_flavor and xa_audit_db_flavor == 'postgres':
|
|
|
+ jdbc_jar_name = default("/hostLevelParams/custom_postgres_jdbc_name", None)
|
|
|
+ audit_jdbc_url = format('jdbc:postgresql://{xa_db_host}/{xa_audit_db_name}')
|
|
|
+ jdbc_driver = "org.postgresql.Driver"
|
|
|
+ elif xa_audit_db_flavor and xa_audit_db_flavor == 'mssql':
|
|
|
+ jdbc_jar_name = default("/hostLevelParams/custom_mssql_jdbc_name", None)
|
|
|
+ audit_jdbc_url = format('jdbc:sqlserver://{xa_db_host};databaseName={xa_audit_db_name}')
|
|
|
+ jdbc_driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
|
|
|
+ elif xa_audit_db_flavor and xa_audit_db_flavor == 'sqla':
|
|
|
+ jdbc_jar_name = default("/hostLevelParams/custom_sqlanywhere_jdbc_name", None)
|
|
|
+ audit_jdbc_url = format('jdbc:sqlanywhere:database={xa_audit_db_name};host={xa_db_host}')
|
|
|
+ jdbc_driver = "sap.jdbc4.sqlanywhere.IDriver"
|
|
|
+
|
|
|
+ downloaded_custom_connector = format("{tmp_dir}/{jdbc_jar_name}") if stack_supports_ranger_audit_db else None
|
|
|
+ driver_curl_source = format("{jdk_location}/{jdbc_jar_name}") if stack_supports_ranger_audit_db else None
|
|
|
+ driver_curl_target = format("{kafka_home}/libs/{jdbc_jar_name}") if stack_supports_ranger_audit_db else None
|
|
|
+
|
|
|
+ xa_audit_db_is_enabled = False
|
|
|
ranger_audit_solr_urls = config['configurations']['ranger-admin-site']['ranger.audit.solr.urls']
|
|
|
- xa_audit_db_is_enabled = config['configurations']['ranger-kafka-audit']['xasecure.audit.destination.db'] if xml_configurations_supported else None
|
|
|
+ if xml_configurations_supported and stack_supports_ranger_audit_db:
|
|
|
+ xa_audit_db_is_enabled = config['configurations']['ranger-kafka-audit']['xasecure.audit.destination.db']
|
|
|
xa_audit_hdfs_is_enabled = config['configurations']['ranger-kafka-audit']['xasecure.audit.destination.hdfs'] if xml_configurations_supported else None
|
|
|
ssl_keystore_password = unicode(config['configurations']['ranger-kafka-policymgr-ssl']['xasecure.policymgr.clientssl.keystore.password']) if xml_configurations_supported else None
|
|
|
ssl_truststore_password = unicode(config['configurations']['ranger-kafka-policymgr-ssl']['xasecure.policymgr.clientssl.truststore.password']) if xml_configurations_supported else None
|