import contextlib
-from copy import deepcopy
import logging
from ..orchestra import run
src_client = config['src']
dest_client = config['dest']
- ceph_config = ctx.ceph.conf.get('global', {})
- ceph_config.update(ctx.ceph.conf.get('client', {}))
- src_ceph_config = deepcopy(ceph_config)
- src_ceph_config.update(ctx.ceph.conf.get(src_client, {}))
- dest_ceph_config = deepcopy(ceph_config)
- dest_ceph_config.update(ctx.ceph.conf.get(dest_client, {}))
-
- src_zone = src_ceph_config['rgw zone']
- dest_zone = dest_ceph_config['rgw zone']
+ src_zone = rgw_utils.zone_for_client(ctx, src_client)
+ dest_zone = rgw_utils.zone_for_client(ctx, dest_client)
log.info("source is %s", src_zone)
log.info("dest is %s", dest_zone)
'zone', 'get', '--rgw-zone', zone])
system_key = zone_info['system_key']
return system_key['access_key'], system_key['secret_key']
+
+def zone_for_client(ctx, client):
+ ceph_config = ctx.ceph.conf.get('global', {})
+ ceph_config.update(ctx.ceph.conf.get('client', {}))
+ ceph_config.update(ctx.ceph.conf.get(client, {}))
+ return ceph_config.get('rgw zone')