|
2 | 2 | import os |
3 | 3 |
|
4 | 4 | import openstack |
5 | | -from keystoneauth1 import session |
6 | | -from keystoneauth1.identity import v3 |
| 5 | +import os_client_config |
7 | 6 |
|
8 | | - |
9 | | -def create_session(app_name="denbi", app_version="1.0"): |
10 | | - """ |
11 | | - Create a keystone session |
12 | | -
|
13 | | - :param app_name: |
14 | | - :param app_version: |
15 | | - :return: Return a openstack session object. |
16 | | - """ |
17 | | - auth = v3.Password(username=os.environ["OS_USERNAME"], |
18 | | - password=os.environ["OS_PASSWORD"], |
19 | | - auth_url=os.environ["OS_AUTH_URL"], |
20 | | - project_name=os.environ["OS_PROJECT_NAME"], |
21 | | - user_domain_name=os.environ["OS_USER_DOMAIN_NAME"], |
22 | | - project_domain_name=os.environ["OS_USER_DOMAIN_NAME"]) |
23 | | - return session.Session(auth=auth, app_name=app_name, app_version=app_version) |
24 | | - |
25 | | - |
26 | | -def create_osclient(session=None): # pylint: disable=W0621 |
| 7 | +def create_osclient(microversions={'compute':'2.79'}): # pylint: disable=W0621 |
27 | 8 | """ |
28 | 9 | Create an authorized openstack.connection.Connection object, that allows |
29 | 10 | REST API calls. |
30 | 11 |
|
31 | | - :param session: Optional, if not set create_session is called |
| 12 | + :param: microversions - a dict containing microversions, where the key |
| 13 | + describes the service and the value the microversion to be used |
| 14 | +
|
32 | 15 | :return: Return an authorized openstack.connection.Connection object |
33 | 16 | """ |
34 | 17 |
|
35 | | - if not session: |
36 | | - session = create_session() |
37 | | - return openstack.connection.Connection(session=session) |
| 18 | + config=os_client_config.get_config() |
| 19 | + |
| 20 | + for service in microversions: |
| 21 | + config.config[f'{service}_default_microversion']=microversions[service] |
| 22 | + |
| 23 | + return openstack.connection.Connection(config=config) |
0 commit comments