Hello,
I am trying to import domains to an RPZ from a stream object instead of a CSV file, but when I do it I get the error that the file header is not valid.
{
"text": "CSV Import file is not valid. First line of the file must be either a valid version number or a valid header line.",
"code": "Client.Ibap.Data",
"Error": "AdmConDataError: None (IBDataError: IB.Data:CSV Import file is not valid. First line of the file must be either a valid version number or a valid header line.)"
}
Below is the Python2 code I wrote for the purpose. Do you know what the problem might be? The ib_file object, which is being imported, has the following format, which is the correct CSV format, but for some reason it cannot be imported via Python.
header-responsepolicycnamerecord,fqdn*,canonical_name,disabled,parent_zone,view
responsepolicycnamerecord,blah.com.threatqrpz,blah.com,FALSE,threatqrpz,default
responsepolicycnamerecord,duck.duck.org.threatqrpz,duck.duck.org,FALSE,threatqrpz,default
responsepolicycnamerecord,badguy.com.threatqrpz,badguy.com,FALSE,threatqrpz,default
##### Re-write the API call to use StringIO instead of one IOC at a time
iocs = ['blah.com', 'duck.duck.org', 'badguy.com']
infoblox_rpz = 'threatqrpz'
dns_view = 'default'
ib_filename = 'infoblox_test_add'
# Add all the domains to a list
ls = [[u'responsepolicycnamerecord', u'{}.{}'.format(data_value, infoblox_rpz), u'{}'.format(data_value), u'FALSE', u'{}'.format(infoblox_rpz), u'{}'.format(dns_view)] for data_value in iocs]
ls.insert(0, [u'header-responsepolicycnamerecord', u'fqdn*', u'canonical_name', u'disabled', u'parent_zone', u'view'])
# Build a stream object
ib_file = None
output = io.BytesIO()
writer = csv.writer(output, delimiter=',')
writer.writerows(ls)
ib_file = output.getvalue()
### 1) Generate an upload url
ep = 'https://{}/wapi/v2.10/fileop'.format(ib_host)
params = {
'_function': 'uploadinit',
'filename': '{}.csv'.format(ib_filename)
}
resp_auth = api_session.post(ep, params=params)
# Get the auth token and the upload URL
token = resp_auth.json().get('token', '')
upload_url = resp_auth.json().get('url', '')
if resp_auth.status_code == 200 and not token:
print 'Infoblox did not return an authentication token. Exiting...'
if resp_auth.status_code == 200 and not upload_url:
print 'Infoblox did not return an upload URL. Exiting...'
### 2) Upload the file to the url returned above
f = {'file': ('{}.csv'.format(ib_filename), ib_file)}
resp_upload = api_session.post(upload_url, files=f)
if not resp_upload.status_code == 200:
print 'The upload failed'
### 3) Start the import
ib_action = 'add'
ib_map = {
'add': 'INSERT',
'merge': 'MERGE',
'delete': 'DELETE'
}
ep = 'https://{}/wapi/v2.10/fileop'.format(ib_host)
params = {
'_function': 'csv_import'
}
data = {
'action': 'START',
'operation': ib_map[ib_action],
'on_error': 'CONTINUE',
'token': token
}
resp_start = api_session.post(
ep,
params=params,
data=json.dumps(data)
)
