ansible-collections/google.cloud
1
0
Fork 0
mirror of https://github.com/ansible-collections/google.cloud.git synced 2025-04-08 11:50:28 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Bigquery (#127)

Browse source 
<!-- This change is generated by MagicModules. -->
/cc @rambleraptor
This commit is contained in:
The Magician 2018-12-06 15:07:57 -08:00 • committed by Alex Stephen
parent 5673c2b7a9
commit d16c2b8629
8 changed files with 443 additions and 452 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

111
plugins/modules/gcp_bigquery_dataset.py
View file

@ -18,14 +18,15 @@
# ---------------------------------------------------------------------------- # ----------------------------------------------------------------------------
from __future__ import absolute_import, division, print_function from __future__ import absolute_import, division, print_function
__metaclass__ = type __metaclass__ = type
################################################################################ ################################################################################
# Documentation # Documentation
################################################################################ ################################################################################
ANSIBLE_METADATA = {'metadata_version': '1.1', 'status': ["preview"], 'supported_by': 'community'} ANSIBLE_METADATA = {'metadata_version': '1.1',
'status': ["preview"],
'supported_by': 'community'}
DOCUMENTATION = ''' DOCUMENTATION = '''
--- ---
@ -305,29 +306,27 @@ def main():
argument_spec=dict( argument_spec=dict(
state=dict(default='present', choices=['present', 'absent'], type='str'), state=dict(default='present', choices=['present', 'absent'], type='str'),
name=dict(type='str'), name=dict(type='str'),
access=dict( access=dict(type='list', elements='dict', options=dict(
type='list', domain=dict(type='str'),
elements='dict', group_by_email=dict(type='str'),
options=dict( role=dict(type='str', choices=['READER', 'WRITER', 'OWNER']),
domain=dict(type='str'), special_group=dict(type='str'),
group_by_email=dict(type='str'), user_by_email=dict(type='str'),
role=dict(type='str', choices=['READER', 'WRITER', 'OWNER']), view=dict(type='dict', options=dict(
special_group=dict(type='str'), dataset_id=dict(required=True, type='str'),
user_by_email=dict(type='str'), project_id=dict(required=True, type='str'),
view=dict( table_id=dict(required=True, type='str')
type='dict', ))
options=dict( )),
dataset_id=dict(required=True, type='str'), project_id=dict(required=True, type='str'), table_id=dict(required=True, type='str') dataset_reference=dict(required=True, type='dict', options=dict(
), dataset_id=dict(required=True, type='str'),
), project_id=dict(type='str')
), )),
),
dataset_reference=dict(required=True, type='dict', options=dict(dataset_id=dict(required=True, type='str'), project_id=dict(type='str'))),
default_table_expiration_ms=dict(type='int'), default_table_expiration_ms=dict(type='int'),
description=dict(type='str'), description=dict(type='str'),
friendly_name=dict(type='str'), friendly_name=dict(type='str'),
labels=dict(type='dict'), labels=dict(type='dict'),
location=dict(default='US', type='str'), location=dict(default='US', type='str')
) )
) )
@ -387,7 +386,7 @@ def resource_to_request(module):
u'description': module.params.get('description'), u'description': module.params.get('description'),
u'friendlyName': module.params.get('friendly_name'), u'friendlyName': module.params.get('friendly_name'),
u'labels': module.params.get('labels'), u'labels': module.params.get('labels'),
u'location': module.params.get('location'), u'location': module.params.get('location')
} }
return_vals = {} return_vals = {}
for k, v in request.items(): for k, v in request.items():
@ -422,8 +421,8 @@ def return_if_object(module, response, kind, allow_not_found=False):
try: try:
module.raise_for_status(response) module.raise_for_status(response)
result = response.json() result = response.json()
except getattr(json.decoder, 'JSONDecodeError', ValueError): except getattr(json.decoder, 'JSONDecodeError', ValueError) as inst:
module.fail_json(msg="Invalid JSON response with error: %s" % response.text) module.fail_json(msg="Invalid JSON response with error: %s" % inst)
if navigate_hash(result, ['error', 'errors']): if navigate_hash(result, ['error', 'errors']):
module.fail_json(msg=navigate_hash(result, ['error', 'errors'])) module.fail_json(msg=navigate_hash(result, ['error', 'errors']))
@ -463,7 +462,7 @@ def response_to_hash(module, response):
u'id': response.get(u'id'), u'id': response.get(u'id'),
u'labels': response.get(u'labels'), u'labels': response.get(u'labels'),
u'lastModifiedTime': response.get(u'lastModifiedTime'), u'lastModifiedTime': response.get(u'lastModifiedTime'),
u'location': response.get(u'location'), u'location': response.get(u'location')
} }
@ -488,28 +487,24 @@ class DatasetAccessArray(object):
return items return items
def _request_for_item(self, item): def _request_for_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'domain': item.get('domain'),
u'domain': item.get('domain'), u'groupByEmail': item.get('group_by_email'),
u'groupByEmail': item.get('group_by_email'), u'role': item.get('role'),
u'role': item.get('role'), u'specialGroup': item.get('special_group'),
u'specialGroup': item.get('special_group'), u'userByEmail': item.get('user_by_email'),
u'userByEmail': item.get('user_by_email'), u'view': DatasetView(item.get('view', {}), self.module).to_request()
u'view': DatasetView(item.get('view', {}), self.module).to_request(), })
}
)
def _response_from_item(self, item): def _response_from_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'domain': item.get(u'domain'),
u'domain': item.get(u'domain'), u'groupByEmail': item.get(u'groupByEmail'),
u'groupByEmail': item.get(u'groupByEmail'), u'role': item.get(u'role'),
u'role': item.get(u'role'), u'specialGroup': item.get(u'specialGroup'),
u'specialGroup': item.get(u'specialGroup'), u'userByEmail': item.get(u'userByEmail'),
u'userByEmail': item.get(u'userByEmail'), u'view': DatasetView(item.get(u'view', {}), self.module).from_response()
u'view': DatasetView(item.get(u'view', {}), self.module).from_response(), })
}
)
class DatasetView(object): class DatasetView(object):
@ -521,14 +516,18 @@ class DatasetView(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{u'datasetId': self.request.get('dataset_id'), u'projectId': self.request.get('project_id'), u'tableId': self.request.get('table_id')} u'datasetId': self.request.get('dataset_id'),
) u'projectId': self.request.get('project_id'),
u'tableId': self.request.get('table_id')
})
def from_response(self): def from_response(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{u'datasetId': self.request.get(u'datasetId'), u'projectId': self.request.get(u'projectId'), u'tableId': self.request.get(u'tableId')} u'datasetId': self.request.get(u'datasetId'),
) u'projectId': self.request.get(u'projectId'),
u'tableId': self.request.get(u'tableId')
})
class DatasetDatasetreference(object): class DatasetDatasetreference(object):
@ -540,10 +539,16 @@ class DatasetDatasetreference(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict({u'datasetId': self.request.get('dataset_id'), u'projectId': self.request.get('project_id')}) return remove_nones_from_dict({
u'datasetId': self.request.get('dataset_id'),
u'projectId': self.request.get('project_id')
})
def from_response(self): def from_response(self):
return remove_nones_from_dict({u'datasetId': self.request.get(u'datasetId'), u'projectId': self.request.get(u'projectId')}) return remove_nones_from_dict({
u'datasetId': self.request.get(u'datasetId'),
u'projectId': self.request.get(u'projectId')
})
if __name__ == '__main__': if __name__ == '__main__':

14
plugins/modules/gcp_bigquery_dataset_facts.py
View file

@ -18,14 +18,15 @@
# ---------------------------------------------------------------------------- # ----------------------------------------------------------------------------
from __future__ import absolute_import, division, print_function from __future__ import absolute_import, division, print_function
__metaclass__ = type __metaclass__ = type
################################################################################ ################################################################################
# Documentation # Documentation
################################################################################ ################################################################################
ANSIBLE_METADATA = {'metadata_version': '1.1', 'status': ["preview"], 'supported_by': 'community'} ANSIBLE_METADATA = {'metadata_version': '1.1',
'status': ["preview"],
'supported_by': 'community'}
DOCUMENTATION = ''' DOCUMENTATION = '''
--- ---
@ -198,7 +199,10 @@ import json
def main(): def main():
module = GcpModule(argument_spec=dict()) module = GcpModule(
argument_spec=dict(
)
)
if not module.params['scopes']: if not module.params['scopes']:
module.params['scopes'] = ['https://www.googleapis.com/auth/bigquery'] module.params['scopes'] = ['https://www.googleapis.com/auth/bigquery']
@ -208,7 +212,9 @@ def main():
items = items.get('datasets') items = items.get('datasets')
else: else:
items = [] items = []
return_value = {'items': items} return_value = {
'items': items
}
module.exit_json(**return_value) module.exit_json(**return_value)

541
plugins/modules/gcp_bigquery_table.py
View file

@ -18,14 +18,15 @@
# ---------------------------------------------------------------------------- # ----------------------------------------------------------------------------
from __future__ import absolute_import, division, print_function from __future__ import absolute_import, division, print_function
__metaclass__ = type __metaclass__ = type
################################################################################ ################################################################################
# Documentation # Documentation
################################################################################ ################################################################################
ANSIBLE_METADATA = {'metadata_version': '1.1', 'status': ["preview"], 'supported_by': 'community'} ANSIBLE_METADATA = {'metadata_version': '1.1',
'status': ["preview"],
'supported_by': 'community'}
DOCUMENTATION = ''' DOCUMENTATION = '''
--- ---
@ -903,107 +904,85 @@ def main():
module = GcpModule( module = GcpModule(
argument_spec=dict( argument_spec=dict(
state=dict(default='present', choices=['present', 'absent'], type='str'), state=dict(default='present', choices=['present', 'absent'], type='str'),
table_reference=dict(type='dict', options=dict(dataset_id=dict(type='str'), project_id=dict(type='str'), table_id=dict(type='str'))), table_reference=dict(type='dict', options=dict(
dataset_id=dict(type='str'),
project_id=dict(type='str'),
table_id=dict(type='str')
)),
description=dict(type='str'), description=dict(type='str'),
friendly_name=dict(type='str'), friendly_name=dict(type='str'),
labels=dict(type='dict'), labels=dict(type='dict'),
name=dict(type='str'), name=dict(type='str'),
view=dict( view=dict(type='dict', options=dict(
type='dict', use_legacy_sql=dict(type='bool'),
options=dict( user_defined_function_resources=dict(type='list', elements='dict', options=dict(
use_legacy_sql=dict(type='bool'), inline_code=dict(type='str'),
user_defined_function_resources=dict( resource_uri=dict(type='str')
type='list', elements='dict', options=dict(inline_code=dict(type='str'), resource_uri=dict(type='str')) ))
), )),
), time_partitioning=dict(type='dict', options=dict(
), expiration_ms=dict(type='int'),
time_partitioning=dict(type='dict', options=dict(expiration_ms=dict(type='int'), type=dict(type='str', choices=['DAY']))), type=dict(type='str', choices=['DAY'])
schema=dict( )),
type='dict', schema=dict(type='dict', options=dict(
options=dict( fields=dict(type='list', elements='dict', options=dict(
fields=dict( description=dict(type='str'),
type='list', fields=dict(type='list', elements='str'),
elements='dict', mode=dict(type='str', choices=['NULLABLE', 'REQUIRED', 'REPEATED']),
options=dict( name=dict(type='str'),
description=dict(type='str'), type=dict(type='str', choices=['STRING', 'BYTES', 'INTEGER', 'FLOAT', 'TIMESTAMP', 'DATE', 'TIME', 'DATETIME', 'RECORD'])
fields=dict(type='list', elements='str'), ))
mode=dict(type='str', choices=['NULLABLE', 'REQUIRED', 'REPEATED']), )),
name=dict(type='str'), encryption_configuration=dict(type='dict', options=dict(
type=dict(type='str', choices=['STRING', 'BYTES', 'INTEGER', 'FLOAT', 'TIMESTAMP', 'DATE', 'TIME', 'DATETIME', 'RECORD']), kms_key_name=dict(type='str')
), )),
)
),
),
encryption_configuration=dict(type='dict', options=dict(kms_key_name=dict(type='str'))),
expiration_time=dict(type='int'), expiration_time=dict(type='int'),
external_data_configuration=dict( external_data_configuration=dict(type='dict', options=dict(
type='dict', autodetect=dict(type='bool'),
options=dict( compression=dict(type='str', choices=['GZIP', 'NONE']),
autodetect=dict(type='bool'), ignore_unknown_values=dict(type='bool'),
compression=dict(type='str', choices=['GZIP', 'NONE']), max_bad_records=dict(default=0, type='int'),
ignore_unknown_values=dict(type='bool'), source_format=dict(type='str', choices=['CSV', 'GOOGLE_SHEETS', 'NEWLINE_DELIMITED_JSON', 'AVRO', 'DATASTORE_BACKUP', 'BIGTABLE']),
max_bad_records=dict(default=0, type='int'), source_uris=dict(type='list', elements='str'),
source_format=dict(type='str', choices=['CSV', 'GOOGLE_SHEETS', 'NEWLINE_DELIMITED_JSON', 'AVRO', 'DATASTORE_BACKUP', 'BIGTABLE']), schema=dict(type='dict', options=dict(
source_uris=dict(type='list', elements='str'), fields=dict(type='list', elements='dict', options=dict(
schema=dict( description=dict(type='str'),
type='dict', fields=dict(type='list', elements='str'),
options=dict( mode=dict(type='str', choices=['NULLABLE', 'REQUIRED', 'REPEATED']),
fields=dict( name=dict(type='str'),
type='list', type=dict(type='str', choices=['STRING', 'BYTES', 'INTEGER', 'FLOAT', 'TIMESTAMP', 'DATE', 'TIME', 'DATETIME', 'RECORD'])
elements='dict', ))
options=dict( )),
description=dict(type='str'), google_sheets_options=dict(type='dict', options=dict(
fields=dict(type='list', elements='str'), skip_leading_rows=dict(default=0, type='int')
mode=dict(type='str', choices=['NULLABLE', 'REQUIRED', 'REPEATED']), )),
name=dict(type='str'), csv_options=dict(type='dict', options=dict(
type=dict(type='str', choices=['STRING', 'BYTES', 'INTEGER', 'FLOAT', 'TIMESTAMP', 'DATE', 'TIME', 'DATETIME', 'RECORD']), allow_jagged_rows=dict(type='bool'),
), allow_quoted_newlines=dict(type='bool'),
) encoding=dict(type='str', choices=['UTF-8', 'ISO-8859-1']),
), field_delimiter=dict(type='str'),
), quote=dict(type='str'),
google_sheets_options=dict(type='dict', options=dict(skip_leading_rows=dict(default=0, type='int'))), skip_leading_rows=dict(default=0, type='int')
csv_options=dict( )),
type='dict', bigtable_options=dict(type='dict', options=dict(
options=dict( ignore_unspecified_column_families=dict(type='bool'),
allow_jagged_rows=dict(type='bool'), read_rowkey_as_string=dict(type='bool'),
allow_quoted_newlines=dict(type='bool'), column_families=dict(type='list', elements='dict', options=dict(
encoding=dict(type='str', choices=['UTF-8', 'ISO-8859-1']), columns=dict(type='list', elements='dict', options=dict(
field_delimiter=dict(type='str'), encoding=dict(type='str', choices=['TEXT', 'BINARY']),
quote=dict(type='str'), field_name=dict(type='str'),
skip_leading_rows=dict(default=0, type='int'), only_read_latest=dict(type='bool'),
), qualifier_string=dict(required=True, type='str'),
), type=dict(type='str', choices=['BYTES', 'STRING', 'INTEGER', 'FLOAT', 'BOOLEAN'])
bigtable_options=dict( )),
type='dict', encoding=dict(type='str', choices=['TEXT', 'BINARY']),
options=dict( family_id=dict(type='str'),
ignore_unspecified_column_families=dict(type='bool'), only_read_latest=dict(type='bool'),
read_rowkey_as_string=dict(type='bool'), type=dict(type='str', choices=['BYTES', 'STRING', 'INTEGER', 'FLOAT', 'BOOLEAN'])
column_families=dict( ))
type='list', ))
elements='dict', )),
options=dict( dataset=dict(type='str')
columns=dict(
type='list',
elements='dict',
options=dict(
encoding=dict(type='str', choices=['TEXT', 'BINARY']),
field_name=dict(type='str'),
only_read_latest=dict(type='bool'),
qualifier_string=dict(required=True, type='str'),
type=dict(type='str', choices=['BYTES', 'STRING', 'INTEGER', 'FLOAT', 'BOOLEAN']),
),
),
encoding=dict(type='str', choices=['TEXT', 'BINARY']),
family_id=dict(type='str'),
only_read_latest=dict(type='bool'),
type=dict(type='str', choices=['BYTES', 'STRING', 'INTEGER', 'FLOAT', 'BOOLEAN']),
),
),
),
),
),
),
dataset=dict(type='str'),
) )
) )
@ -1066,7 +1045,7 @@ def resource_to_request(module):
u'schema': TableSchema(module.params.get('schema', {}), module).to_request(), u'schema': TableSchema(module.params.get('schema', {}), module).to_request(),
u'encryptionConfiguration': TableEncryptionconfiguration(module.params.get('encryption_configuration', {}), module).to_request(), u'encryptionConfiguration': TableEncryptionconfiguration(module.params.get('encryption_configuration', {}), module).to_request(),
u'expirationTime': module.params.get('expiration_time'), u'expirationTime': module.params.get('expiration_time'),
u'externalDataConfiguration': TableExternaldataconfiguration(module.params.get('external_data_configuration', {}), module).to_request(), u'externalDataConfiguration': TableExternaldataconfiguration(module.params.get('external_data_configuration', {}), module).to_request()
} }
return_vals = {} return_vals = {}
for k, v in request.items(): for k, v in request.items():
@ -1101,8 +1080,8 @@ def return_if_object(module, response, kind, allow_not_found=False):
try: try:
module.raise_for_status(response) module.raise_for_status(response)
result = response.json() result = response.json()
except getattr(json.decoder, 'JSONDecodeError', ValueError): except getattr(json.decoder, 'JSONDecodeError', ValueError) as inst:
module.fail_json(msg="Invalid JSON response with error: %s" % response.text) module.fail_json(msg="Invalid JSON response with error: %s" % inst)
if navigate_hash(result, ['error', 'errors']): if navigate_hash(result, ['error', 'errors']):
module.fail_json(msg=navigate_hash(result, ['error', 'errors'])) module.fail_json(msg=navigate_hash(result, ['error', 'errors']))
@ -1151,7 +1130,7 @@ def response_to_hash(module, response):
u'schema': TableSchema(response.get(u'schema', {}), module).from_response(), u'schema': TableSchema(response.get(u'schema', {}), module).from_response(),
u'encryptionConfiguration': TableEncryptionconfiguration(response.get(u'encryptionConfiguration', {}), module).from_response(), u'encryptionConfiguration': TableEncryptionconfiguration(response.get(u'encryptionConfiguration', {}), module).from_response(),
u'expirationTime': response.get(u'expirationTime'), u'expirationTime': response.get(u'expirationTime'),
u'externalDataConfiguration': TableExternaldataconfiguration(response.get(u'externalDataConfiguration', {}), module).from_response(), u'externalDataConfiguration': TableExternaldataconfiguration(response.get(u'externalDataConfiguration', {}), module).from_response()
} }
@ -1164,14 +1143,18 @@ class TableTablereference(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{u'datasetId': self.request.get('dataset_id'), u'projectId': self.request.get('project_id'), u'tableId': self.request.get('table_id')} u'datasetId': self.request.get('dataset_id'),
) u'projectId': self.request.get('project_id'),
u'tableId': self.request.get('table_id')
})
def from_response(self): def from_response(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{u'datasetId': self.request.get(u'datasetId'), u'projectId': self.request.get(u'projectId'), u'tableId': self.request.get(u'tableId')} u'datasetId': self.request.get(u'datasetId'),
) u'projectId': self.request.get(u'projectId'),
u'tableId': self.request.get(u'tableId')
})
class TableView(object): class TableView(object):
@ -1183,24 +1166,18 @@ class TableView(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'useLegacySql': self.request.get('use_legacy_sql'),
u'useLegacySql': self.request.get('use_legacy_sql'), u'userDefinedFunctionResources':
u'userDefinedFunctionResources': TableUserdefinedfunctionresourcesArray( TableUserdefinedfunctionresourcesArray(self.request.get('user_defined_function_resources', []), self.module).to_request()
self.request.get('user_defined_function_resources', []), self.module })
).to_request(),
}
)
def from_response(self): def from_response(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'useLegacySql': self.request.get(u'useLegacySql'),
u'useLegacySql': self.request.get(u'useLegacySql'), u'userDefinedFunctionResources':
u'userDefinedFunctionResources': TableUserdefinedfunctionresourcesArray( TableUserdefinedfunctionresourcesArray(self.request.get(u'userDefinedFunctionResources', []), self.module).from_response()
self.request.get(u'userDefinedFunctionResources', []), self.module })
).from_response(),
}
)
class TableUserdefinedfunctionresourcesArray(object): class TableUserdefinedfunctionresourcesArray(object):
@ -1224,10 +1201,16 @@ class TableUserdefinedfunctionresourcesArray(object):
return items return items
def _request_for_item(self, item): def _request_for_item(self, item):
return remove_nones_from_dict({u'inlineCode': item.get('inline_code'), u'resourceUri': item.get('resource_uri')}) return remove_nones_from_dict({
u'inlineCode': item.get('inline_code'),
u'resourceUri': item.get('resource_uri')
})
def _response_from_item(self, item): def _response_from_item(self, item):
return remove_nones_from_dict({u'inlineCode': item.get(u'inlineCode'), u'resourceUri': item.get(u'resourceUri')}) return remove_nones_from_dict({
u'inlineCode': item.get(u'inlineCode'),
u'resourceUri': item.get(u'resourceUri')
})
class TableTimepartitioning(object): class TableTimepartitioning(object):
@ -1239,10 +1222,16 @@ class TableTimepartitioning(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict({u'expirationMs': self.request.get('expiration_ms'), u'type': self.request.get('type')}) return remove_nones_from_dict({
u'expirationMs': self.request.get('expiration_ms'),
u'type': self.request.get('type')
})
def from_response(self): def from_response(self):
return remove_nones_from_dict({u'expirationMs': self.request.get(u'expirationMs'), u'type': self.request.get(u'type')}) return remove_nones_from_dict({
u'expirationMs': self.request.get(u'expirationMs'),
u'type': self.request.get(u'type')
})
class TableStreamingbuffer(object): class TableStreamingbuffer(object):
@ -1254,22 +1243,18 @@ class TableStreamingbuffer(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'estimatedBytes': self.request.get('estimated_bytes'),
u'estimatedBytes': self.request.get('estimated_bytes'), u'estimatedRows': self.request.get('estimated_rows'),
u'estimatedRows': self.request.get('estimated_rows'), u'oldestEntryTime': self.request.get('oldest_entry_time')
u'oldestEntryTime': self.request.get('oldest_entry_time'), })
}
)
def from_response(self): def from_response(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'estimatedBytes': self.request.get(u'estimatedBytes'),
u'estimatedBytes': self.request.get(u'estimatedBytes'), u'estimatedRows': self.request.get(u'estimatedRows'),
u'estimatedRows': self.request.get(u'estimatedRows'), u'oldestEntryTime': self.request.get(u'oldestEntryTime')
u'oldestEntryTime': self.request.get(u'oldestEntryTime'), })
}
)
class TableSchema(object): class TableSchema(object):
@ -1281,10 +1266,14 @@ class TableSchema(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict({u'fields': TableFieldsArray(self.request.get('fields', []), self.module).to_request()}) return remove_nones_from_dict({
u'fields': TableFieldsArray(self.request.get('fields', []), self.module).to_request()
})
def from_response(self): def from_response(self):
return remove_nones_from_dict({u'fields': TableFieldsArray(self.request.get(u'fields', []), self.module).from_response()}) return remove_nones_from_dict({
u'fields': TableFieldsArray(self.request.get(u'fields', []), self.module).from_response()
})
class TableFieldsArray(object): class TableFieldsArray(object):
@ -1308,26 +1297,22 @@ class TableFieldsArray(object):
return items return items
def _request_for_item(self, item): def _request_for_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'description': item.get('description'),
u'description': item.get('description'), u'fields': item.get('fields'),
u'fields': item.get('fields'), u'mode': item.get('mode'),
u'mode': item.get('mode'), u'name': item.get('name'),
u'name': item.get('name'), u'type': item.get('type')
u'type': item.get('type'), })
}
)
def _response_from_item(self, item): def _response_from_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'description': item.get(u'description'),
u'description': item.get(u'description'), u'fields': item.get(u'fields'),
u'fields': item.get(u'fields'), u'mode': item.get(u'mode'),
u'mode': item.get(u'mode'), u'name': item.get(u'name'),
u'name': item.get(u'name'), u'type': item.get(u'type')
u'type': item.get(u'type'), })
}
)
class TableEncryptionconfiguration(object): class TableEncryptionconfiguration(object):
@ -1339,10 +1324,14 @@ class TableEncryptionconfiguration(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict({u'kmsKeyName': self.request.get('kms_key_name')}) return remove_nones_from_dict({
u'kmsKeyName': self.request.get('kms_key_name')
})
def from_response(self): def from_response(self):
return remove_nones_from_dict({u'kmsKeyName': self.request.get(u'kmsKeyName')}) return remove_nones_from_dict({
u'kmsKeyName': self.request.get(u'kmsKeyName')
})
class TableExternaldataconfiguration(object): class TableExternaldataconfiguration(object):
@ -1354,36 +1343,32 @@ class TableExternaldataconfiguration(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'autodetect': self.request.get('autodetect'),
u'autodetect': self.request.get('autodetect'), u'compression': self.request.get('compression'),
u'compression': self.request.get('compression'), u'ignoreUnknownValues': self.request.get('ignore_unknown_values'),
u'ignoreUnknownValues': self.request.get('ignore_unknown_values'), u'maxBadRecords': self.request.get('max_bad_records'),
u'maxBadRecords': self.request.get('max_bad_records'), u'sourceFormat': self.request.get('source_format'),
u'sourceFormat': self.request.get('source_format'), u'sourceUris': self.request.get('source_uris'),
u'sourceUris': self.request.get('source_uris'), u'schema': TableSchema(self.request.get('schema', {}), self.module).to_request(),
u'schema': TableSchema(self.request.get('schema', {}), self.module).to_request(), u'googleSheetsOptions': TableGooglesheetsoptions(self.request.get('google_sheets_options', {}), self.module).to_request(),
u'googleSheetsOptions': TableGooglesheetsoptions(self.request.get('google_sheets_options', {}), self.module).to_request(), u'csvOptions': TableCsvoptions(self.request.get('csv_options', {}), self.module).to_request(),
u'csvOptions': TableCsvoptions(self.request.get('csv_options', {}), self.module).to_request(), u'bigtableOptions': TableBigtableoptions(self.request.get('bigtable_options', {}), self.module).to_request()
u'bigtableOptions': TableBigtableoptions(self.request.get('bigtable_options', {}), self.module).to_request(), })
}
)
def from_response(self): def from_response(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'autodetect': self.request.get(u'autodetect'),
u'autodetect': self.request.get(u'autodetect'), u'compression': self.request.get(u'compression'),
u'compression': self.request.get(u'compression'), u'ignoreUnknownValues': self.request.get(u'ignoreUnknownValues'),
u'ignoreUnknownValues': self.request.get(u'ignoreUnknownValues'), u'maxBadRecords': self.request.get(u'maxBadRecords'),
u'maxBadRecords': self.request.get(u'maxBadRecords'), u'sourceFormat': self.request.get(u'sourceFormat'),
u'sourceFormat': self.request.get(u'sourceFormat'), u'sourceUris': self.request.get(u'sourceUris'),
u'sourceUris': self.request.get(u'sourceUris'), u'schema': TableSchema(self.request.get(u'schema', {}), self.module).from_response(),
u'schema': TableSchema(self.request.get(u'schema', {}), self.module).from_response(), u'googleSheetsOptions': TableGooglesheetsoptions(self.request.get(u'googleSheetsOptions', {}), self.module).from_response(),
u'googleSheetsOptions': TableGooglesheetsoptions(self.request.get(u'googleSheetsOptions', {}), self.module).from_response(), u'csvOptions': TableCsvoptions(self.request.get(u'csvOptions', {}), self.module).from_response(),
u'csvOptions': TableCsvoptions(self.request.get(u'csvOptions', {}), self.module).from_response(), u'bigtableOptions': TableBigtableoptions(self.request.get(u'bigtableOptions', {}), self.module).from_response()
u'bigtableOptions': TableBigtableoptions(self.request.get(u'bigtableOptions', {}), self.module).from_response(), })
}
)
class TableSchema(object): class TableSchema(object):
@ -1395,10 +1380,14 @@ class TableSchema(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict({u'fields': TableFieldsArray(self.request.get('fields', []), self.module).to_request()}) return remove_nones_from_dict({
u'fields': TableFieldsArray(self.request.get('fields', []), self.module).to_request()
})
def from_response(self): def from_response(self):
return remove_nones_from_dict({u'fields': TableFieldsArray(self.request.get(u'fields', []), self.module).from_response()}) return remove_nones_from_dict({
u'fields': TableFieldsArray(self.request.get(u'fields', []), self.module).from_response()
})
class TableFieldsArray(object): class TableFieldsArray(object):
@ -1422,26 +1411,22 @@ class TableFieldsArray(object):
return items return items
def _request_for_item(self, item): def _request_for_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'description': item.get('description'),
u'description': item.get('description'), u'fields': item.get('fields'),
u'fields': item.get('fields'), u'mode': item.get('mode'),
u'mode': item.get('mode'), u'name': item.get('name'),
u'name': item.get('name'), u'type': item.get('type')
u'type': item.get('type'), })
}
)
def _response_from_item(self, item): def _response_from_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'description': item.get(u'description'),
u'description': item.get(u'description'), u'fields': item.get(u'fields'),
u'fields': item.get(u'fields'), u'mode': item.get(u'mode'),
u'mode': item.get(u'mode'), u'name': item.get(u'name'),
u'name': item.get(u'name'), u'type': item.get(u'type')
u'type': item.get(u'type'), })
}
)
class TableGooglesheetsoptions(object): class TableGooglesheetsoptions(object):
@ -1453,10 +1438,14 @@ class TableGooglesheetsoptions(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict({u'skipLeadingRows': self.request.get('skip_leading_rows')}) return remove_nones_from_dict({
u'skipLeadingRows': self.request.get('skip_leading_rows')
})
def from_response(self): def from_response(self):
return remove_nones_from_dict({u'skipLeadingRows': self.request.get(u'skipLeadingRows')}) return remove_nones_from_dict({
u'skipLeadingRows': self.request.get(u'skipLeadingRows')
})
class TableCsvoptions(object): class TableCsvoptions(object):
@ -1468,28 +1457,24 @@ class TableCsvoptions(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'allowJaggedRows': self.request.get('allow_jagged_rows'),
u'allowJaggedRows': self.request.get('allow_jagged_rows'), u'allowQuotedNewlines': self.request.get('allow_quoted_newlines'),
u'allowQuotedNewlines': self.request.get('allow_quoted_newlines'), u'encoding': self.request.get('encoding'),
u'encoding': self.request.get('encoding'), u'fieldDelimiter': self.request.get('field_delimiter'),
u'fieldDelimiter': self.request.get('field_delimiter'), u'quote': self.request.get('quote'),
u'quote': self.request.get('quote'), u'skipLeadingRows': self.request.get('skip_leading_rows')
u'skipLeadingRows': self.request.get('skip_leading_rows'), })
}
)
def from_response(self): def from_response(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'allowJaggedRows': self.request.get(u'allowJaggedRows'),
u'allowJaggedRows': self.request.get(u'allowJaggedRows'), u'allowQuotedNewlines': self.request.get(u'allowQuotedNewlines'),
u'allowQuotedNewlines': self.request.get(u'allowQuotedNewlines'), u'encoding': self.request.get(u'encoding'),
u'encoding': self.request.get(u'encoding'), u'fieldDelimiter': self.request.get(u'fieldDelimiter'),
u'fieldDelimiter': self.request.get(u'fieldDelimiter'), u'quote': self.request.get(u'quote'),
u'quote': self.request.get(u'quote'), u'skipLeadingRows': self.request.get(u'skipLeadingRows')
u'skipLeadingRows': self.request.get(u'skipLeadingRows'), })
}
)
class TableBigtableoptions(object): class TableBigtableoptions(object):
@ -1501,22 +1486,18 @@ class TableBigtableoptions(object):
self.request = {} self.request = {}
def to_request(self): def to_request(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'ignoreUnspecifiedColumnFamilies': self.request.get('ignore_unspecified_column_families'),
u'ignoreUnspecifiedColumnFamilies': self.request.get('ignore_unspecified_column_families'), u'readRowkeyAsString': self.request.get('read_rowkey_as_string'),
u'readRowkeyAsString': self.request.get('read_rowkey_as_string'), u'columnFamilies': TableColumnfamiliesArray(self.request.get('column_families', []), self.module).to_request()
u'columnFamilies': TableColumnfamiliesArray(self.request.get('column_families', []), self.module).to_request(), })
}
)
def from_response(self): def from_response(self):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'ignoreUnspecifiedColumnFamilies': self.request.get(u'ignoreUnspecifiedColumnFamilies'),
u'ignoreUnspecifiedColumnFamilies': self.request.get(u'ignoreUnspecifiedColumnFamilies'), u'readRowkeyAsString': self.request.get(u'readRowkeyAsString'),
u'readRowkeyAsString': self.request.get(u'readRowkeyAsString'), u'columnFamilies': TableColumnfamiliesArray(self.request.get(u'columnFamilies', []), self.module).from_response()
u'columnFamilies': TableColumnfamiliesArray(self.request.get(u'columnFamilies', []), self.module).from_response(), })
}
)
class TableColumnfamiliesArray(object): class TableColumnfamiliesArray(object):
@ -1540,26 +1521,22 @@ class TableColumnfamiliesArray(object):
return items return items
def _request_for_item(self, item): def _request_for_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'columns': TableColumnsArray(item.get('columns', []), self.module).to_request(),
u'columns': TableColumnsArray(item.get('columns', []), self.module).to_request(), u'encoding': item.get('encoding'),
u'encoding': item.get('encoding'), u'familyId': item.get('family_id'),
u'familyId': item.get('family_id'), u'onlyReadLatest': item.get('only_read_latest'),
u'onlyReadLatest': item.get('only_read_latest'), u'type': item.get('type')
u'type': item.get('type'), })
}
)
def _response_from_item(self, item): def _response_from_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'columns': TableColumnsArray(item.get(u'columns', []), self.module).from_response(),
u'columns': TableColumnsArray(item.get(u'columns', []), self.module).from_response(), u'encoding': item.get(u'encoding'),
u'encoding': item.get(u'encoding'), u'familyId': item.get(u'familyId'),
u'familyId': item.get(u'familyId'), u'onlyReadLatest': item.get(u'onlyReadLatest'),
u'onlyReadLatest': item.get(u'onlyReadLatest'), u'type': item.get(u'type')
u'type': item.get(u'type'), })
}
)
class TableColumnsArray(object): class TableColumnsArray(object):
@ -1583,26 +1560,22 @@ class TableColumnsArray(object):
return items return items
def _request_for_item(self, item): def _request_for_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'encoding': item.get('encoding'),
u'encoding': item.get('encoding'), u'fieldName': item.get('field_name'),
u'fieldName': item.get('field_name'), u'onlyReadLatest': item.get('only_read_latest'),
u'onlyReadLatest': item.get('only_read_latest'), u'qualifierString': item.get('qualifier_string'),
u'qualifierString': item.get('qualifier_string'), u'type': item.get('type')
u'type': item.get('type'), })
}
)
def _response_from_item(self, item): def _response_from_item(self, item):
return remove_nones_from_dict( return remove_nones_from_dict({
{ u'encoding': item.get(u'encoding'),
u'encoding': item.get(u'encoding'), u'fieldName': item.get(u'fieldName'),
u'fieldName': item.get(u'fieldName'), u'onlyReadLatest': item.get(u'onlyReadLatest'),
u'onlyReadLatest': item.get(u'onlyReadLatest'), u'qualifierString': item.get(u'qualifierString'),
u'qualifierString': item.get(u'qualifierString'), u'type': item.get(u'type')
u'type': item.get(u'type'), })
}
)
if __name__ == '__main__': if __name__ == '__main__':

15
plugins/modules/gcp_bigquery_table_facts.py
View file

@ -18,14 +18,15 @@
# ---------------------------------------------------------------------------- # ----------------------------------------------------------------------------
from __future__ import absolute_import, division, print_function from __future__ import absolute_import, division, print_function
__metaclass__ = type __metaclass__ = type
################################################################################ ################################################################################
# Documentation # Documentation
################################################################################ ################################################################################
ANSIBLE_METADATA = {'metadata_version': '1.1', 'status': ["preview"], 'supported_by': 'community'} ANSIBLE_METADATA = {'metadata_version': '1.1',
'status': ["preview"],
'supported_by': 'community'}
DOCUMENTATION = ''' DOCUMENTATION = '''
--- ---
@ -512,7 +513,11 @@ import json
def main(): def main():
module = GcpModule(argument_spec=dict(dataset=dict(type='str'))) module = GcpModule(
argument_spec=dict(
dataset=dict(type='str')
)
)
if not module.params['scopes']: if not module.params['scopes']:
module.params['scopes'] = ['https://www.googleapis.com/auth/bigquery'] module.params['scopes'] = ['https://www.googleapis.com/auth/bigquery']
@ -522,7 +527,9 @@ def main():
items = items.get('tables') items = items.get('tables')
else: else:
items = [] items = []
return_value = {'items': items} return_value = {
'items': items
}
module.exit_json(**return_value) module.exit_json(**return_value)

3
tests/integration/gcp_bigquery_dataset/defaults/main.yml
View file

@ -1,2 +1,3 @@
--- ---
resource_name: "{{ resource_prefix }}" # defaults file
resource_name: '{{resource_prefix}}'

74
tests/integration/gcp_bigquery_dataset/tasks/main.yml
View file

@ -15,23 +15,23 @@
# Pre-test setup # Pre-test setup
- name: delete a dataset - name: delete a dataset
gcp_bigquery_dataset: gcp_bigquery_dataset:
name: my_example_dataset name: my_example_dataset
dataset_reference: dataset_reference:
dataset_id: my_example_dataset dataset_id: my_example_dataset
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: absent state: absent
#---------------------------------------------------------- #----------------------------------------------------------
- name: create a dataset - name: create a dataset
gcp_bigquery_dataset: gcp_bigquery_dataset:
name: my_example_dataset name: my_example_dataset
dataset_reference: dataset_reference:
dataset_id: my_example_dataset dataset_id: my_example_dataset
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: present state: present
register: result register: result
- name: assert changed is true - name: assert changed is true
assert: assert:
@ -49,17 +49,17 @@
- name: verify that command succeeded - name: verify that command succeeded
assert: assert:
that: that:
- results['resources'] | length >= 1 - results['items'] | length >= 1
# ---------------------------------------------------------------------------- # ----------------------------------------------------------------------------
- name: create a dataset that already exists - name: create a dataset that already exists
gcp_bigquery_dataset: gcp_bigquery_dataset:
name: my_example_dataset name: my_example_dataset
dataset_reference: dataset_reference:
dataset_id: my_example_dataset dataset_id: my_example_dataset
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: present state: present
register: result register: result
- name: assert changed is false - name: assert changed is false
assert: assert:
@ -69,13 +69,13 @@
#---------------------------------------------------------- #----------------------------------------------------------
- name: delete a dataset - name: delete a dataset
gcp_bigquery_dataset: gcp_bigquery_dataset:
name: my_example_dataset name: my_example_dataset
dataset_reference: dataset_reference:
dataset_id: my_example_dataset dataset_id: my_example_dataset
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: absent state: absent
register: result register: result
- name: assert changed is true - name: assert changed is true
assert: assert:
@ -93,17 +93,17 @@
- name: verify that command succeeded - name: verify that command succeeded
assert: assert:
that: that:
- results['resources'] | length == 0 - results['items'] | length == 0
# ---------------------------------------------------------------------------- # ----------------------------------------------------------------------------
- name: delete a dataset that does not exist - name: delete a dataset that does not exist
gcp_bigquery_dataset: gcp_bigquery_dataset:
name: my_example_dataset name: my_example_dataset
dataset_reference: dataset_reference:
dataset_id: my_example_dataset dataset_id: my_example_dataset
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: absent state: absent
register: result register: result
- name: assert changed is false - name: assert changed is false
assert: assert:

3
tests/integration/gcp_bigquery_table/defaults/main.yml
View file

@ -1,2 +1,3 @@
--- ---
resource_name: "{{ resource_prefix }}" # defaults file
resource_name: '{{resource_prefix}}'

134
tests/integration/gcp_bigquery_table/tasks/main.yml
View file

@ -15,39 +15,39 @@
# Pre-test setup # Pre-test setup
- name: create a dataset - name: create a dataset
gcp_bigquery_dataset: gcp_bigquery_dataset:
name: example_dataset name: example_dataset
dataset_reference: dataset_reference:
dataset_id: example_dataset dataset_id: example_dataset
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: present state: present
register: dataset register: dataset
- name: delete a table - name: delete a table
gcp_bigquery_table: gcp_bigquery_table:
name: example_table name: example_table
dataset: example_dataset dataset: example_dataset
table_reference: table_reference:
dataset_id: example_dataset dataset_id: example_dataset
project_id: "{{ gcp_project }}" project_id: "{{ gcp_project }}"
table_id: example_table table_id: example_table
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: absent state: absent
#---------------------------------------------------------- #----------------------------------------------------------
- name: create a table - name: create a table
gcp_bigquery_table: gcp_bigquery_table:
name: example_table name: example_table
dataset: example_dataset dataset: example_dataset
table_reference: table_reference:
dataset_id: example_dataset dataset_id: example_dataset
project_id: "{{ gcp_project }}" project_id: "{{ gcp_project }}"
table_id: example_table table_id: example_table
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: present state: present
register: result register: result
- name: assert changed is true - name: assert changed is true
assert: assert:
@ -66,20 +66,20 @@
- name: verify that command succeeded - name: verify that command succeeded
assert: assert:
that: that:
- results['resources'] | length >= 1 - results['items'] | length >= 1
# ---------------------------------------------------------------------------- # ----------------------------------------------------------------------------
- name: create a table that already exists - name: create a table that already exists
gcp_bigquery_table: gcp_bigquery_table:
name: example_table name: example_table
dataset: example_dataset dataset: example_dataset
table_reference: table_reference:
dataset_id: example_dataset dataset_id: example_dataset
project_id: "{{ gcp_project }}" project_id: "{{ gcp_project }}"
table_id: example_table table_id: example_table
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: present state: present
register: result register: result
- name: assert changed is false - name: assert changed is false
assert: assert:
@ -89,16 +89,16 @@
#---------------------------------------------------------- #----------------------------------------------------------
- name: delete a table - name: delete a table
gcp_bigquery_table: gcp_bigquery_table:
name: example_table name: example_table
dataset: example_dataset dataset: example_dataset
table_reference: table_reference:
dataset_id: example_dataset dataset_id: example_dataset
project_id: "{{ gcp_project }}" project_id: "{{ gcp_project }}"
table_id: example_table table_id: example_table
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: absent state: absent
register: result register: result
- name: assert changed is true - name: assert changed is true
assert: assert:
@ -117,20 +117,20 @@
- name: verify that command succeeded - name: verify that command succeeded
assert: assert:
that: that:
- results['resources'] | length == 0 - results['items'] | length == 0
# ---------------------------------------------------------------------------- # ----------------------------------------------------------------------------
- name: delete a table that does not exist - name: delete a table that does not exist
gcp_bigquery_table: gcp_bigquery_table:
name: example_table name: example_table
dataset: example_dataset dataset: example_dataset
table_reference: table_reference:
dataset_id: example_dataset dataset_id: example_dataset
project_id: "{{ gcp_project }}" project_id: "{{ gcp_project }}"
table_id: example_table table_id: example_table
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: absent state: absent
register: result register: result
- name: assert changed is false - name: assert changed is false
assert: assert:
@ -139,15 +139,13 @@
- result.has_key('kind') == False - result.has_key('kind') == False
#--------------------------------------------------------- #---------------------------------------------------------
# Post-test teardown # Post-test teardown
# If errors happen, don't crash the playbook!
- name: delete a dataset - name: delete a dataset
gcp_bigquery_dataset: gcp_bigquery_dataset:
name: example_dataset name: example_dataset
dataset_reference: dataset_reference:
dataset_id: example_dataset dataset_id: example_dataset
project: "{{ gcp_project }}" project: "{{ gcp_project }}"
auth_kind: "{{ gcp_cred_kind }}" auth_kind: "{{ gcp_cred_kind }}"
service_account_file: "{{ gcp_cred_file }}" service_account_file: "{{ gcp_cred_file }}"
state: absent state: absent
register: dataset register: dataset
ignore_errors: true