code: def command(self, cluster_id, command, *args):
          
          cluster = self._storage[cluster_id]
          try:
              return getattr(cluster, command)(*args)
          except AttributeError:
              raise ValueError("Cannot issue the command %r to ShardedCluster %s"
                               % (command, cluster_id))
docs: Call a ShardedCluster method.