Method _run_main_command

awscli/customizations/emr/ssh.py:174–211

(self, parsed_args, parsed_globals)

    ]

    def _run_main_command(self, parsed_args, parsed_globals):
        master_dns = sshutils.validate_and_find_master_dns(
            session=self._session,
            parsed_globals=parsed_globals,
            cluster_id=parsed_args.cluster_id,
        )

        key_file = parsed_args.key_pair_file
        sshutils.validate_ssh_with_key_file(key_file)
        f = tempfile.NamedTemporaryFile(delete=False)
        if emrutils.which('ssh') or emrutils.which('ssh.exe'):
            ssh_options = _build_ssh_options(parsed_args.ssh_options)
            command = ['ssh'] + ssh_options + [
                '-o', 'ServerAliveInterval=10',
                '-i', parsed_args.key_pair_file,
                constants.SSH_USER + '@' + master_dns,
                '-t',
            ]
            if parsed_args.command:
                command.append(parsed_args.command)
        else:
            if parsed_args.ssh_options:
                sys.stderr.write(PUTTY_SSH_OPTIONS_MSG)
            command = [
                'putty', '-ssh', '-i', parsed_args.key_pair_file,
                constants.SSH_USER + '@' + master_dns, '-t',
            ]
            if parsed_args.command:
                f.write(parsed_args.command)
                f.write('\nread -n1 -r -p "Command completed. Press any key."')
                command.append('-m')
                command.append(f.name)

        f.close()
        print(' '.join(command))
        rc = subprocess.call(command)
        os.remove(f.name)
        return rc


class Put(Command):