diff --git a/lib/ansible/modules/cloud/amazon/aws_netapp_cvs_pool.py b/lib/ansible/modules/cloud/amazon/aws_netapp_cvs_pool.py
new file mode 100644
index 0000000000..d1b5f9aaa7
--- /dev/null
+++ b/lib/ansible/modules/cloud/amazon/aws_netapp_cvs_pool.py
@@ -0,0 +1,267 @@
+#!/usr/bin/python
+
+# (c) 2019, NetApp Inc.
+# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
+
+"""AWS Cloud Volumes Services - Manage Pools"""
+
+from __future__ import absolute_import, division, print_function
+
+__metaclass__ = type
+
+ANSIBLE_METADATA = {'metadata_version': '1.1',
+                    'status': ['preview'],
+                    'supported_by': 'community'}
+
+
+DOCUMENTATION = '''
+
+module: aws_netapp_cvs_pool
+
+short_description: NetApp AWS Cloud Volumes Service Manage Pools.
+extends_documentation_fragment:
+    - netapp.awscvs
+version_added: '2.9'
+author: NetApp Ansible Team (@carchi8py) <ng-ansibleteam@netapp.com>
+description:
+    - Create, Update, Delete Pool on AWS Cloud Volumes Service.
+
+options:
+    state:
+        description:
+        - Whether the specified pool should exist or not.
+        choices: ['present', 'absent']
+        required: true
+        type: str
+    region:
+        description:
+        - The region to which the Pool is associated.
+        required: true
+        type: str
+    name:
+        description:
+        - pool name ( The human readable name of the Pool )
+        - name can be used for create, update and delete operations
+        required: true
+        type: str
+    serviceLevel:
+        description:
+        - The service level of the Pool
+        - can be used with pool create, update operations
+        choices: ['basic', 'standard', 'extreme']
+        type: str
+    sizeInBytes:
+        description:
+        - Size of the Pool in bytes
+        - can be used with pool create, update operations
+        - minimum value is 4000000000000 bytes
+        type: int
+    vendorID:
+        description:
+        - A vendor ID for the Pool. E.g. an ID allocated by a vendor service for the Pool.
+        - can be used with pool create, update operations
+        - must be unique
+        type: str
+    from_name:
+        description:
+        - rename the existing pool name ( The human readable name of the Pool )
+        - I(from_name) is the existing name, and I(name) the new name
+        - can be used with update operation
+        type: str
+'''
+
+EXAMPLES = """
+- name: Create a new Pool
+  aws_netapp_cvs_pool:
+    state: present
+    name: TestPoolBB12
+    serviceLevel: extreme
+    sizeInBytes: 4000000000000
+    vendorID: ansiblePoolTestVendorBB12
+    region: us-east-1
+    api_url: cds-aws-bundles.netapp.com
+    api_key: MyAPiKey
+    secret_key: MySecretKey
+
+- name: Delete a Pool
+  aws_netapp_cvs_pool:
+    state: absent
+    name: TestPoolBB7
+    region: us-east-1
+    api_url: cds-aws-bundles.netapp.com
+    api_key: MyAPiKey
+    secret_key: MySecretKey
+
+- name: Update a Pool
+  aws_netapp_cvs_pool:
+    state: present
+    from_name: TestPoolBB12
+    name: Mynewpool7
+    vendorID: ansibleVendorMynewpool15
+    serviceLevel: extreme
+    sizeInBytes: 4000000000000
+    region: us-east-1
+    api_url: cds-aws-bundles.netapp.com
+    api_key: MyAPiKey
+    secret_key: MySecretKey
+
+"""
+
+RETURN = '''
+'''
+
+import ansible.module_utils.netapp as netapp_utils
+from ansible.module_utils.basic import AnsibleModule
+from ansible.module_utils.netapp_module import NetAppModule
+from ansible.module_utils.netapp import AwsCvsRestAPI
+
+
+class NetAppAWSCVS(object):
+    '''Class  for  Pool operations '''
+
+    def __init__(self):
+        """
+        Parse arguments, setup state variables,
+        """
+        self.argument_spec = netapp_utils.aws_cvs_host_argument_spec()
+        self.argument_spec.update(dict(
+            state=dict(required=True, choices=['present', 'absent']),
+            region=dict(required=True, type='str'),
+            name=dict(required=True, type='str'),
+            from_name=dict(required=False, type='str'),
+            serviceLevel=dict(required=False, choices=['basic', 'standard', 'extreme'], type='str'),
+            sizeInBytes=dict(required=False, type='int'),
+            vendorID=dict(required=False, type='str'),
+        ))
+        self.module = AnsibleModule(
+            argument_spec=self.argument_spec,
+            supports_check_mode=True
+        )
+
+        self.na_helper = NetAppModule()
+        self.parameters = self.na_helper.set_parameters(self.module.params)
+        self.restApi = AwsCvsRestAPI(self.module)
+        self.sizeInBytes_min_value = 4000000000000
+
+    def get_aws_netapp_cvs_pool(self, name=None):
+        """
+        Returns Pool object if exists else Return None
+        """
+        pool_info = None
+
+        if name is None:
+            name = self.parameters['name']
+
+        pools, error = self.restApi.get('Pools')
+
+        if error is None and pools is not None:
+            for pool in pools:
+                if 'name' in pool and pool['region'] == self.parameters['region']:
+                    if pool['name'] == name:
+                        pool_info = pool
+                        break
+
+        return pool_info
+
+    def create_aws_netapp_cvs_pool(self):
+        """
+        Create a pool
+        """
+        api = 'Pools'
+
+        for key in ['serviceLevel', 'sizeInBytes', 'vendorID']:
+            if key not in self.parameters.keys() or self.parameters[key] is None:
+                self.module.fail_json(changed=False, msg="Mandatory key '%s' required" % (key))
+
+        pool = {
+            "name": self.parameters['name'],
+            "region": self.parameters['region'],
+            "serviceLevel": self.parameters['serviceLevel'],
+            "sizeInBytes": self.parameters['sizeInBytes'],
+            "vendorID": self.parameters['vendorID']
+        }
+
+        response, error = self.restApi.post(api, pool)
+        if error is not None:
+            self.module.fail_json(changed=False, msg=error)
+
+    def update_aws_netapp_cvs_pool(self, update_pool_info, pool_id):
+        """
+        Update a pool
+        """
+        api = 'Pools/' + pool_id
+
+        pool = {
+            "name": update_pool_info['name'],
+            "region": self.parameters['region'],
+            "serviceLevel": update_pool_info['serviceLevel'],
+            "sizeInBytes": update_pool_info['sizeInBytes'],
+            "vendorID": update_pool_info['vendorID']
+        }
+
+        response, error = self.restApi.put(api, pool)
+        if error is not None:
+            self.module.fail_json(changed=False, msg=error)
+
+    def delete_aws_netapp_cvs_pool(self, pool_id):
+        """
+        Delete a pool
+        """
+        api = 'Pools/' + pool_id
+        data = None
+        response, error = self.restApi.delete(api, data)
+
+        if error is not None:
+            self.module.fail_json(changed=False, msg=error)
+
+    def apply(self):
+        """
+        Perform pre-checks, call functions and exit
+        """
+        update_required = False
+        cd_action = None
+
+        if 'sizeInBytes' in self.parameters.keys() and self.parameters['sizeInBytes'] < self.sizeInBytes_min_value:
+            self.module.fail_json(changed=False, msg="sizeInBytes should be greater than  or equal to %d" % (self.sizeInBytes_min_value))
+
+        current = self.get_aws_netapp_cvs_pool()
+        if self.parameters.get('from_name'):
+            existing = self.get_aws_netapp_cvs_pool(self.parameters['from_name'])
+            rename = self.na_helper.is_rename_action(existing, current)
+            if rename is None:
+                self.module.fail_json(changed=False, msg="unable to rename pool: '%s' does not exist" % self.parameters['from_name'])
+            if rename:
+                current = existing
+        else:
+            cd_action = self.na_helper.get_cd_action(current, self.parameters)
+
+        if cd_action is None and self.parameters['state'] == 'present':
+            keys_to_check = ['name', 'vendorID', 'sizeInBytes', 'serviceLevel']
+            update_pool_info, update_required = self.na_helper.compare_and_update_values(current, self.parameters, keys_to_check)
+
+            if update_required is True:
+                self.na_helper.changed = True
+                cd_action = 'update'
+
+        if self.na_helper.changed:
+            if self.module.check_mode:
+                pass
+            else:
+                if cd_action == 'update':
+                    self.update_aws_netapp_cvs_pool(update_pool_info, current['poolId'])
+                elif cd_action == 'create':
+                    self.create_aws_netapp_cvs_pool()
+                elif cd_action == 'delete':
+                    self.delete_aws_netapp_cvs_pool(current['poolId'])
+
+        self.module.exit_json(changed=self.na_helper.changed)
+
+
+def main():
+    '''Main Function'''
+    aws_cvs_netapp_pool = NetAppAWSCVS()
+    aws_cvs_netapp_pool.apply()
+
+
+if __name__ == '__main__':
+    main()
diff --git a/test/units/modules/cloud/amazon/test_aws_netapp_cvs_pool.py b/test/units/modules/cloud/amazon/test_aws_netapp_cvs_pool.py
new file mode 100644
index 0000000000..5530916187
--- /dev/null
+++ b/test/units/modules/cloud/amazon/test_aws_netapp_cvs_pool.py
@@ -0,0 +1,263 @@
+# (c) 2019, NetApp, Inc
+# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
+
+''' Unit tests for AWS Cloud Volumes Services - Manage Pools '''
+
+from __future__ import (absolute_import, division, print_function)
+__metaclass__ = type
+import json
+import pytest
+
+from units.compat import unittest
+from units.compat.mock import patch, Mock
+from ansible.module_utils import basic
+from ansible.module_utils._text import to_bytes
+from requests import Response
+from ansible.modules.cloud.amazon.aws_netapp_cvs_pool \
+    import NetAppAWSCVS as pool_module
+
+
+def set_module_args(args):
+    """prepare arguments so that they will be picked up during module creation"""
+    args = json.dumps({'ANSIBLE_MODULE_ARGS': args})
+    basic._ANSIBLE_ARGS = to_bytes(args)  # pylint: disable=protected-access
+
+
+class AnsibleExitJson(Exception):
+    """Exception class to be raised by module.exit_json and caught by the test case"""
+    pass
+
+
+class AnsibleFailJson(Exception):
+    """Exception class to be raised by module.fail_json and caught by the test case"""
+    pass
+
+
+def exit_json(*args, **kwargs):  # pylint: disable=unused-argument
+    """function to patch over exit_json; package return data into an exception"""
+    if 'changed' not in kwargs:
+        kwargs['changed'] = False
+    raise AnsibleExitJson(kwargs)
+
+
+def fail_json(*args, **kwargs):  # pylint: disable=unused-argument
+    """function to patch over fail_json; package return data into an exception"""
+    kwargs['failed'] = True
+    raise AnsibleFailJson(kwargs)
+
+
+class TestMyModule(unittest.TestCase):
+    ''' a group of related Unit Tests '''
+
+    def setUp(self):
+        self.mock_module_helper = patch.multiple(basic.AnsibleModule,
+                                                 exit_json=exit_json,
+                                                 fail_json=fail_json)
+        self.mock_module_helper.start()
+        self.addCleanup(self.mock_module_helper.stop)
+
+    def set_default_args_fail_check(self):
+        return dict({
+            'from_name': 'TestPoolAA',
+            'name': 'TestPoolAA_new',
+            'serviceLevel': 'standard',
+            'sizeInBytes': 4000000000000,
+            'vendorID': 'ansiblePoolTestVendorA',
+            'region': 'us-east-1',
+            'api_url': 'hostname.invalid',
+            'api_key': 'myapikey',
+            'secret_key': 'mysecretkey'
+        })
+
+    def set_default_args_pass_check(self):
+        return dict({
+            'state': 'present',
+            'from_name': 'TestPoolAA',
+            'name': 'TestPoolAA_new',
+            'serviceLevel': 'standard',
+            'sizeInBytes': 4000000000000,
+            'vendorID': 'ansiblePoolTestVendorA',
+            'region': 'us-east-1',
+            'api_url': 'hostname.invalid',
+            'api_key': 'myapikey',
+            'secret_key': 'mysecretkey'
+        })
+
+    def set_args_create_aws_netapp_cvs_pool(self):
+        return dict({
+            'state': 'present',
+            'name': 'TestPoolAA',
+            'serviceLevel': 'standard',
+            'sizeInBytes': 4000000000000,
+            'vendorID': 'ansiblePoolTestVendorA',
+            'region': 'us-east-1',
+            'api_url': 'hostname.invalid',
+            'api_key': 'myapikey',
+            'secret_key': 'mysecretkey'
+        })
+
+    def set_args_update_aws_netapp_cvs_pool(self):
+        return dict({
+            'state': 'present',
+            'from_name': 'TestPoolAA',
+            'name': 'TestPoolAA_new',
+            'serviceLevel': 'standard',
+            'sizeInBytes': 4000000000000,
+            'vendorID': 'ansiblePoolTestVendorA',
+            'region': 'us-east-1',
+            'api_url': 'hostname.invalid',
+            'api_key': 'myapikey',
+            'secret_key': 'mysecretkey'
+        })
+
+    def set_args_delete_aws_netapp_cvs_pool(self):
+        return dict({
+            'state': 'absent',
+            'name': 'TestPoolAA',
+            'region': 'us-east-1',
+            'api_url': 'hostname.invalid',
+            'api_key': 'myapikey',
+            'secret_key': 'mysecretkey'
+        })
+
+    def test_module_fail_when_required_args_missing(self):
+        ''' required arguments are reported as errors '''
+        with pytest.raises(AnsibleFailJson) as exc:
+            set_module_args(self.set_default_args_fail_check())
+            pool_module()
+        print('Info: test_module_fail_when_required_args_missing: %s' % exc.value.args[0]['msg'])
+
+    def test_module_pass_when_required_args_present(self):
+        ''' required arguments are present '''
+        with pytest.raises(AnsibleExitJson) as exc:
+            set_module_args(self.set_default_args_pass_check())
+            pool_module()
+            exit_json(changed=True, msg="Induced arguments check")
+        print('Info: test_module_pass_when_required_args_present: %s' % exc.value.args[0]['msg'])
+        assert exc.value.args[0]['changed']
+
+    @patch('ansible.modules.cloud.amazon.aws_netapp_cvs_pool.NetAppAWSCVS.get_aws_netapp_cvs_pool')
+    @patch('ansible.module_utils.netapp.AwsCvsRestAPI.put')
+    def test_update_aws_netapp_cvs_pool_pass(self, get_put_api, get_aws_api):
+        set_module_args(self.set_args_update_aws_netapp_cvs_pool())
+        my_obj = pool_module()
+        my_pool = {
+            "name": "Dummyname",
+            "poolId": "1f63b3d0-4fd4-b4fe-1ed6-c62f5f20d975",
+            "region": "us-east-1",
+            "serviceLevel": "extreme",
+            "sizeInBytes": 40000000000000000,
+            "state": "available",
+            "vendorID": "Dummy"
+        }
+        get_aws_api.return_value = my_pool
+        get_put_api.return_value = my_pool, None
+        with pytest.raises(AnsibleExitJson) as exc:
+            my_obj.apply()
+        print('Info: test_update_aws_netapp_cvs_pool_pass: %s' % repr(exc.value))
+        assert exc.value.args[0]['changed']
+
+    @patch('ansible.modules.cloud.amazon.aws_netapp_cvs_pool.NetAppAWSCVS.get_aws_netapp_cvs_pool')
+    @patch('ansible.module_utils.netapp.AwsCvsRestAPI.put')
+    def test_update_aws_netapp_cvs_pool_fail(self, get_put_api, get_aws_api):
+        set_module_args(self.set_args_update_aws_netapp_cvs_pool())
+        my_obj = pool_module()
+        my_pool = {
+            "name": "Dummyname",
+            "poolId": "1f63b3d0-4fd4-b4fe-1ed6-c62f5f20d975",
+            "region": "us-east-1",
+            "serviceLevel": "extreme",
+            "sizeInBytes": 40000000000000000,
+            "state": "available",
+            "vendorID": "Dummy"
+        }
+        get_put_api.return_value = my_pool, "Error"
+        get_aws_api.return_value = my_pool
+        with pytest.raises(AnsibleFailJson) as exc:
+            my_obj.apply()
+        print('Info: test_update_aws_netapp_cvs_pool_fail: %s' % repr(exc.value))
+        assert exc.value.args[0]['msg'] is not None
+
+    @patch('ansible.modules.cloud.amazon.aws_netapp_cvs_pool.NetAppAWSCVS.get_aws_netapp_cvs_pool')
+    @patch('ansible.module_utils.netapp.AwsCvsRestAPI.post')
+    def test_create_aws_netapp_cvs_pool_pass(self, get_post_api, get_aws_api):
+        set_module_args(self.set_args_create_aws_netapp_cvs_pool())
+        my_obj = pool_module()
+        my_pool = {
+            "name": "Dummyname",
+            "poolId": "1f63b3d0-4fd4-b4fe-1ed6-c62f5f20d975",
+            "region": "us-east-1",
+            "serviceLevel": "extreme",
+            "sizeInBytes": 40000000000000000,
+            "state": "available",
+            "vendorID": "Dummy"
+        }
+        get_aws_api.return_value = None
+        get_post_api.return_value = None, None
+        with pytest.raises(AnsibleExitJson) as exc:
+            my_obj.apply()
+        print('Info: test_create_aws_netapp_cvs_pool_pass: %s' % repr(exc.value))
+        assert exc.value.args[0]['changed']
+
+    @patch('ansible.modules.cloud.amazon.aws_netapp_cvs_pool.NetAppAWSCVS.get_aws_netapp_cvs_pool')
+    @patch('ansible.module_utils.netapp.AwsCvsRestAPI.post')
+    def test_create_aws_netapp_cvs_pool_fail(self, get_post_api, get_aws_api):
+        set_module_args(self.set_args_create_aws_netapp_cvs_pool())
+        my_obj = pool_module()
+        my_pool = {
+            "name": "Dummyname",
+            "poolId": "1f63b3d0-4fd4-b4fe-1ed6-c62f5f20d975",
+            "region": "us-east-1",
+            "serviceLevel": "extreme",
+            "sizeInBytes": 40000000000000000,
+            "state": "available",
+            "vendorID": "Dummy"
+        }
+        get_post_api.return_value = my_pool, "Error"
+        get_aws_api.return_value = None
+        with pytest.raises(AnsibleFailJson) as exc:
+            my_obj.apply()
+        print('Info: test_create_aws_netapp_cvs_pool_fail: %s' % repr(exc.value))
+        assert exc.value.args[0]['msg'] is not None
+
+    @patch('ansible.modules.cloud.amazon.aws_netapp_cvs_pool.NetAppAWSCVS.get_aws_netapp_cvs_pool')
+    @patch('ansible.module_utils.netapp.AwsCvsRestAPI.delete')
+    def test_delete_aws_netapp_cvs_pool_pass(self, get_delete_api, get_aws_api):
+        set_module_args(self.set_args_delete_aws_netapp_cvs_pool())
+        my_obj = pool_module()
+        my_pool = {
+            "name": "Dummyname",
+            "poolId": "1f63b3d0-4fd4-b4fe-1ed6-c62f5f20d975",
+            "region": "us-east-1",
+            "serviceLevel": "extreme",
+            "sizeInBytes": 40000000000000000,
+            "state": "available",
+            "vendorID": "Dummy"
+        }
+        get_aws_api.return_value = my_pool
+        get_delete_api.return_value = None, None
+        with pytest.raises(AnsibleExitJson) as exc:
+            my_obj.apply()
+        print('Info: test_delete_aws_netapp_cvs_pool_pass: %s' % repr(exc.value))
+        assert exc.value.args[0]['changed']
+
+    @patch('ansible.modules.cloud.amazon.aws_netapp_cvs_pool.NetAppAWSCVS.get_aws_netapp_cvs_pool')
+    @patch('ansible.module_utils.netapp.AwsCvsRestAPI.delete')
+    def test_delete_aws_netapp_cvs_pool_fail(self, get_delete_api, get_aws_api):
+        set_module_args(self.set_args_delete_aws_netapp_cvs_pool())
+        my_obj = pool_module()
+        my_pool = {
+            "name": "Dummyname",
+            "poolId": "1f63b3d0-4fd4-b4fe-1ed6-c62f5f20d975",
+            "region": "us-east-1",
+            "serviceLevel": "extreme",
+            "sizeInBytes": 40000000000000000,
+            "state": "available",
+            "vendorID": "Dummy"
+        }
+        get_delete_api.return_value = my_pool, "Error"
+        get_aws_api.return_value = my_pool
+        with pytest.raises(AnsibleFailJson) as exc:
+            my_obj.apply()
+        print('Info: test_delete_aws_netapp_cvs_pool_fail: %s' % repr(exc.value))
+        assert exc.value.args[0]['msg'] is not None