add exceptions for OCI and simplify push-debug file regex
This commit is contained in:
parent
7452f8fa44
commit
5ebeee4c8d
|
@ -77,6 +77,15 @@ ALKIRA_BASE_URI = f'https://{ALKIRA_TENANT}/api'
|
||||||
# Set default headers
|
# Set default headers
|
||||||
headers = {'Content-Type': "application/json"}
|
headers = {'Content-Type': "application/json"}
|
||||||
|
|
||||||
|
# Naming exceptions
|
||||||
|
service_exceptions = {
|
||||||
|
"saas": "internet",
|
||||||
|
"pan": "panfw",
|
||||||
|
"ftntfw": "ftnt-fw-",
|
||||||
|
"chkpfw": "chkp-fw-",
|
||||||
|
"ocivcnconnectors": "oci-vcn-connectors"
|
||||||
|
}
|
||||||
|
|
||||||
# Authenticate
|
# Authenticate
|
||||||
body = {'userName': ALKIRA_USERNAME,
|
body = {'userName': ALKIRA_USERNAME,
|
||||||
'password': ALKIRA_PASSWORD}
|
'password': ALKIRA_PASSWORD}
|
||||||
|
@ -96,10 +105,10 @@ logging.info(f'Tenant ID: {tenantNetworkId}')
|
||||||
print(json_file)
|
print(json_file)
|
||||||
|
|
||||||
# Do Things
|
# Do Things
|
||||||
connector_result = re.match(r'(.*)\/?(\w+)(\d+)', json_file)
|
connector_result = re.match(r'(\w+)(\d+)', json_file)
|
||||||
connector_name = connector_result.group(1)
|
connector_name = connector_result.group(1)
|
||||||
connector_number = connector_result.group(2)
|
connector_number = connector_result.group(2)
|
||||||
|
logging.debug(f'Connector Name: {connector_name} - Number: {connecter_nunber}')
|
||||||
with open (json_file, 'r') as f:
|
with open (json_file, 'r') as f:
|
||||||
body = json.load(f)
|
body = json.load(f)
|
||||||
if args.pretty:
|
if args.pretty:
|
||||||
|
@ -107,6 +116,8 @@ with open (json_file, 'r') as f:
|
||||||
else:
|
else:
|
||||||
print(json.dumps(body))
|
print(json.dumps(body))
|
||||||
|
|
||||||
|
if connector_name in service_exceptions.keys():
|
||||||
|
connector_name = service_exceptions[connector_name]
|
||||||
url = f'{ALKIRA_BASE_URI}/tenantnetworks/{tenantNetworkId}/{connector_name}'
|
url = f'{ALKIRA_BASE_URI}/tenantnetworks/{tenantNetworkId}/{connector_name}'
|
||||||
response = session.post(url, data=json.dumps(body), headers=headers)
|
response = session.post(url, data=json.dumps(body), headers=headers)
|
||||||
print(response.status_code)
|
print(response.status_code)
|
||||||
|
|
5
push.py
5
push.py
|
@ -85,7 +85,8 @@ service_exceptions = {
|
||||||
"saas": "internet",
|
"saas": "internet",
|
||||||
"pan": "panfw",
|
"pan": "panfw",
|
||||||
"ftntfw": "ftnt-fw-",
|
"ftntfw": "ftnt-fw-",
|
||||||
"chkpfw": "chkp-fw-"
|
"chkpfw": "chkp-fw-",
|
||||||
|
"ocivcnconnectors": "oci-vcn-connectors"
|
||||||
}
|
}
|
||||||
|
|
||||||
def alkira_login():
|
def alkira_login():
|
||||||
|
@ -184,6 +185,8 @@ for connector in config.sections():
|
||||||
|
|
||||||
logging.debug(json.dumps(body))
|
logging.debug(json.dumps(body))
|
||||||
logging.info(f'Pushing {connector_name} to {cxp} (network segment: {segments}; group: {group})')
|
logging.info(f'Pushing {connector_name} to {cxp} (network segment: {segments}; group: {group})')
|
||||||
|
if connector_name in service_exceptions.keys():
|
||||||
|
connector_name = service_exceptions[connector_name]
|
||||||
r = alkira_post(s, f'/tenantnetworks/{tenantNetworkId}/{connector_name}', body)
|
r = alkira_post(s, f'/tenantnetworks/{tenantNetworkId}/{connector_name}', body)
|
||||||
logging.info(r.status_code)
|
logging.info(r.status_code)
|
||||||
logging.debug(r.content)
|
logging.debug(r.content)
|
||||||
|
|
Loading…
Reference in New Issue