diff --git a/drush.services.yml b/drush.services.yml
new file mode 100644
index 0000000..05b749a
--- /dev/null
+++ b/drush.services.yml
@@ -0,0 +1,5 @@
+services:
+  migrate_tools.commands:
+    class: \Drupal\migrate_tools\Commands\MigrateToolsCommands
+    tags:
+      - { name: drush.command }
diff --git a/src/Commands/MigrateToolsCommands.php b/src/Commands/MigrateToolsCommands.php
new file mode 100644
index 0000000..1c40b74
--- /dev/null
+++ b/src/Commands/MigrateToolsCommands.php
@@ -0,0 +1,493 @@
+<?php
+namespace Drupal\migrate_tools\Commands;
+
+use Drupal\Component\Utility\Unicode;
+use Drupal\migrate\Exception\RequirementsException;
+use Drupal\migrate\Plugin\MigrationInterface;
+use Drupal\migrate\Plugin\RequirementsInterface;
+use Drupal\migrate_tools\MigrateExecutable;
+use Drupal\migrate_tools\DrushLogMigrateMessage;
+use Drupal\Core\Datetime\DateFormatter;
+use Drupal\migrate_plus\Entity\MigrationGroup;
+use Drush\Commands\DrushCommands;
+use Exception;
+
+/**
+ * Migrate Tools Drush commands
+ */
+class MigrateToolsCommands extends DrushCommands {
+
+  /**
+   * List all migrations with current status.
+   *
+   * @command migrate-status
+   * @param string $migration_names Restrict to a comma-separated list of migrations. Optional
+   * @option group A comma-separated list of migration groups to list
+   * @option tag Name of the migration tag to list
+   * @option names-only Only return names, not all the details (faster)
+   * @usage migrate-status
+   *   Retrieve status for all migrations
+   * @usage migrate-status --group=beer
+   *   Retrieve status for all migrations in a given group
+   * @usage migrate-status --tag=user
+   *   Retrieve status for all migrations with a given tag
+   * @usage migrate-status --group=beer --tag=user
+   *   Retrieve status for all migrations in the beer group and with the user tag
+   * @usage migrate-status beer_term,beer_node
+   *   Retrieve status for specific migrations
+   * @validate-module-enabled migrate_tools
+   * @aliases ms
+   */
+  public function status($migration_names = '', $options = ['group' => null, 'tag' => null, 'names-only' => null])
+  {
+    $names_only = drush_get_option('names-only');
+
+    $migrations = $this->migrationList($migration_names);
+
+    $table = [];
+    // Take it one group at a time, listing the migrations within each group.
+    foreach ($migrations as $group_id => $migration_list) {
+      $group = MigrationGroup::load($group_id);
+      $group_name = !empty($group) ? "{$group->label()} ({$group->id()})" : $group_id;
+      if ($names_only) {
+        $table[] = [
+          dt('Group: @name', array('@name' => $group_name))
+        ];
+      }
+      else {
+        $table[] = [
+          dt('Group: @name', array('@name' => $group_name)),
+          dt('Status'),
+          dt('Total'),
+          dt('Imported'),
+          dt('Unprocessed'),
+          dt('Last imported'),
+        ];
+      }
+      foreach ($migration_list as $migration_id => $migration) {
+        try {
+          $map = $migration->getIdMap();
+          $imported = $map->importedCount();
+          $source_plugin = $migration->getSourcePlugin();
+        }
+        catch (Exception $e) {
+          $this->logger()->warning(dt('Failure retrieving information on @migration: @message',
+            ['@migration' => $migration_id, '@message' => $e->getMessage()]));
+          continue;
+        }
+        if ($names_only) {
+          $table[] = [$migration_id];
+        }
+        else {
+          try {
+            $source_rows = $source_plugin->count();
+            // -1 indicates uncountable sources.
+            if ($source_rows == -1) {
+              $source_rows = dt('N/A');
+              $unprocessed = dt('N/A');
+            }
+            else {
+              $unprocessed = $source_rows - $map->processedCount();
+            }
+          }
+          catch (Exception $e) {
+            $this->output()->writeln($e->getMessage());
+            $this->logger()->warning(dt('Could not retrieve source count from @migration: @message',
+              ['@migration' => $migration_id, '@message' => $e->getMessage()]));
+            $source_rows = dt('N/A');
+            $unprocessed = dt('N/A');
+          }
+
+          $status = $migration->getStatusLabel();
+          $migrate_last_imported_store = \Drupal::keyValue('migrate_last_imported');
+          $last_imported = $migrate_last_imported_store->get($migration->id(), FALSE);
+          if ($last_imported) {
+            /** @var DateFormatter $date_formatter */
+            $date_formatter = \Drupal::service('date.formatter');
+            $last_imported = $date_formatter->format($last_imported / 1000,
+              'custom', 'Y-m-d H:i:s');
+          }
+          else {
+            $last_imported = '';
+          }
+          $table[] = [$migration_id, $status, $source_rows, $imported, $unprocessed, $last_imported];
+        }
+      }
+    }
+    drush_print_table($table);
+  }
+
+  /**
+   * Perform one or more migration processes.
+   *
+   * @command migrate-import
+   * @param string $migration_names ID of migration(s) to import. Delimit multiple using commas.
+   * @param array $options
+   * @throws \Exception
+   * @option all Process all migrations.
+   * @option group A comma-separated list of migration groups to import
+   * @option tag Name of the migration tag to import
+   * @option limit Limit on the number of items to process in each migration
+   * @option feedback Frequency of progress messages, in items processed
+   * @option idlist Comma-separated list of IDs to import
+   * @option update  In addition to processing unprocessed items from the source, update previously-imported items with the current data
+   * @option force Force an operation to run, even if all dependencies are not satisfied
+   * @option execute-dependencies Execute all dependent migrations first.
+   * @usage migrate-import --all
+   *   Perform all migrations
+   * @usage migrate-import --group=beer
+   *   Import all migrations in the beer group
+   * @usage migrate-import --tag=user
+   *   Import all migrations with the user tag
+   * @usage migrate-import --group=beer --tag=user
+   *   Import all migrations in the beer group and with the user tag
+   * @usage migrate-import beer_term,beer_node
+   *   Import new terms and nodes
+   * @usage migrate-import beer_user --limit=2
+   *   Import no more than 2 users
+   * @usage migrate-import beer_user --idlist=5
+   *   Import the user record with source ID 5
+   * @validate-module-enabled migrate_tools
+   * @aliases mi
+   */
+  public function import($migration_names = '', $options = ['all' => null, 'group' => null, 'tag' => null, 'limit' => null, 'feedback' => null, 'idlist' => null, 'update' => null, 'force' => null, 'execute-dependencies' => null])
+  {
+    $group_names = drush_get_option('group');
+    $tag_names = drush_get_option('tag');
+    $all = drush_get_option('all');
+    $options = [];
+    if (!$all && !$group_names && !$migration_names && !$tag_names) {
+      throw new \Exception(dt('You must specify --all, --group, --tag or one or more migration names separated by commas'));
+    }
+
+    foreach (['limit', 'feedback', 'idlist', 'update', 'force'] as $option) {
+      if (drush_get_option($option)) {
+        $options[$option] = drush_get_option($option);
+      }
+    }
+
+    $migrations = $this->migrationList($migration_names);
+    if (empty($migrations)) {
+      $this->logger()->info(dt('No migrations found.'), 'error');
+    }
+
+    // Take it one group at a time, importing the migrations within each group.
+    foreach ($migrations as $group_id => $migration_list) {
+      array_walk($migration_list, array($this, 'executeMigration'), $options);
+    }
+  }
+
+  /**
+   * Executes a single migration. If the --execute-dependencies option was given,
+   * the migration's dependencies will also be executed first.
+   *
+   * @param \Drupal\migrate\Plugin\MigrationInterface $migration
+   *  The migration to execute.
+   * @param string $migration_id
+   *  The migration ID (not used, just an artifact of array_walk()).
+   * @param array $options
+   *  Additional options for the migration.
+   */
+  protected function executeMigration(MigrationInterface $migration, $migration_id,  array $options = []) {
+    $log = new DrushLogMigrateMessage();
+
+    if (drush_get_option('execute-dependencies')) {
+      if ($required_IDS = $migration->get('requirements')) {
+        $manager = \Drupal::service('plugin.manager.config_entity_migration');
+        $required_migrations = $manager->createInstances($required_IDS);
+        $dependency_options = array_merge($options, ['is_dependency' => TRUE]);
+        array_walk($required_migrations, array($this, 'executeMigration'), $dependency_options);
+      }
+    }
+    if (!empty($options['force'])) {
+      $migration->set('requirements', []);
+    }
+    if (!empty($options['update'])) {
+      $migration->getIdMap()->prepareUpdate();
+    }
+    $executable = new MigrateExecutable($migration, $log, $options);
+    // drush_op() provides --simulate support
+    drush_op(array($executable, 'import'));
+  }
+
+  /**
+   * Rollback one or more migrations.
+   *
+   * @command migrate-rollback
+   * @param string $migration_names Name of migration(s) to rollback. Delimit multiple using commas.
+   * @param array $options
+   * @throws \Exception
+   * @option all Process all migrations.
+   * @option group A comma-separated list of migration groups to rollback
+   * @option tag ID of the migration tag to rollback
+   * @option feedback Frequency of progress messages, in items processed
+   * @usage migrate-rollback --all
+   *   Perform all migrations
+   * @usage migrate-rollback --group=beer
+   *   Rollback all migrations in the beer group
+   * @usage migrate-rollback --tag=user
+   *   Rollback all migrations with the user tag
+   * @usage migrate-rollback --group=beer --tag=user
+   *   Rollback all migrations in the beer group and with the user tag
+   * @usage migrate-rollback beer_term,beer_node
+   *   Rollback imported terms and nodes
+   * @validate-module-enabled migrate_tools
+   * @aliases mr
+   */
+  public function rollback($migration_names = '', $options = ['all' => null, 'group' => null, 'tag' => null, 'feedback' => null])
+  {
+    $group_names = drush_get_option('group');
+    $tag_names = drush_get_option('tag');
+    $all = drush_get_option('all');
+    $options = [];
+    if (!$all && !$group_names && !$migration_names && !$tag_names) {
+      throw new \Exception(dt('You must specify --all, --group, --tag, or one or more migration names separated by commas'));
+    }
+
+    if (drush_get_option('feedback')) {
+      $options['feedback'] = drush_get_option('feedback');
+    }
+
+    $log = new DrushLogMigrateMessage();
+
+    $migrations = $this->migrationList($migration_names);
+    if (empty($migrations)) {
+      $this->logger()->error(dt('No migrations found.'));
+    }
+
+    // Take it one group at a time, rolling back the migrations within each group.
+    foreach ($migrations as $group_id => $migration_list) {
+      // Roll back in reverse order.
+      $migration_list = array_reverse($migration_list);
+      foreach ($migration_list as $migration_id => $migration) {
+        $executable = new MigrateExecutable($migration, $log, $options);
+        // drush_op() provides --simulate support.
+        drush_op(array($executable, 'rollback'));
+      }
+    }
+  }
+
+  /**
+   * Stop an active migration operation.
+   *
+   * @command migrate-stop
+   * @param string $migration_id ID of migration to stop
+   * @validate-module-enabled migrate_tools
+   * @aliases mst
+   */
+  public function stop($migration_id = '')
+  {
+    /** @var MigrationInterface $migration */
+    $migration = \Drupal::service('plugin.manager.migration')->createInstance($migration_id);
+    if ($migration) {
+      $status = $migration->getStatus();
+      switch ($status) {
+        case MigrationInterface::STATUS_IDLE:
+          $this->logger()->warning(dt('Migration @id is idle', ['@id' => $migration_id]));
+          break;
+        case MigrationInterface::STATUS_DISABLED:
+          $this->logger()->warning(dt('Migration @id is disabled', ['@id' => $migration_id]));
+          break;
+        case MigrationInterface::STATUS_STOPPING:
+          $this->logger()->warning(dt('Migration @id is already stopping', ['@id' => $migration_id]));
+          break;
+        default:
+          $migration->interruptMigration(MigrationInterface::RESULT_STOPPED);
+          $this->logger()->info(dt('Migration @id requested to stop', ['@id' => $migration_id]));
+          break;
+      }
+    }
+    else {
+      $this->logger()->error(dt('Migration @id does not exist', ['@id' => $migration_id]));
+    }
+  }
+
+  /**
+   * Reset a active migration's status to idle.
+   *
+   * @command migrate-reset-status
+   * @param string $migration_id ID of migration to reset
+   * @validate-module-enabled migrate_tools
+   * @aliases mrs
+   */
+  public function resetStatus($migration_id = '')
+  {
+    /** @var MigrationInterface $migration */
+    $migration = \Drupal::service('plugin.manager.migration')->createInstance($migration_id);
+    if ($migration) {
+      $status = $migration->getStatus();
+      if ($status == MigrationInterface::STATUS_IDLE) {
+        $this->logger()->warning(dt('Migration @id is already Idle', ['@id' => $migration_id]));
+      }
+      else {
+        $migration->setStatus(MigrationInterface::STATUS_IDLE);
+        $this->logger()->info(dt('Migration @id reset to Idle', ['@id' => $migration_id]));
+      }
+    }
+    else {
+      $this->logger()->error(dt('Migration @id does not exist', ['@id' => $migration_id]));
+    }
+  }
+
+  /**
+   * View any messages associated with a migration.
+   *
+   * @command migrate-messages
+   * @param string $migration_id ID of the migration
+   * @option csv Export messages as a CSV
+   * @usage migrate-messages MyNode
+   *   Show all messages for the MyNode migration
+   * @validate-module-enabled migrate_tools
+   * @aliases mmsg
+   */
+  public function messages($migration_id, $options = ['csv' => null])
+  {
+    /** @var MigrationInterface $migration */
+    $migration = \Drupal::service('plugin.manager.migration')->createInstance($migration_id);
+    if ($migration) {
+      $map = $migration->getIdMap();
+      $first = TRUE;
+      $table = [];
+      foreach ($map->getMessageIterator() as $row) {
+        unset($row->msgid);
+        if ($first) {
+          // @todo: Ideally, replace sourceid* with source key names. Or, should
+          // getMessageIterator() do that?
+          foreach ($row as $column => $value) {
+            $table[0][] = $column;
+          }
+          $first = FALSE;
+        }
+        $table[] = (array)$row;
+      }
+      if (empty($table)) {
+        $this->logger()->info(dt('No messages for this migration'));
+      }
+      else {
+        if (drush_get_option('csv')) {
+          foreach ($table as $row) {
+            fputcsv(STDOUT, $row);
+          }
+        }
+        else {
+          $widths = [];
+          foreach ($table[0] as $header) {
+            $widths[] = strlen($header) + 1;
+          }
+          drush_print_table($table, TRUE, $widths);
+        }
+      }
+    }
+    else {
+      $this->logger()->error(dt('Migration @id does not exist', ['@id' => $migration_id]));
+    }
+  }
+
+  /**
+   * List the fields available for mapping in a source.
+   *
+   * @command migrate-fields-source
+   * @param string $migration_id ID of the migration
+   * @usage migrate-fields-source my_node
+   *   List fields for the source in the my_node migration
+   * @validate-module-enabled migrate_tools
+   * @aliases mfs
+   */
+  public function fieldsSource($migration_id)
+  {
+    /** @var MigrationInterface $migration */
+    $migration = \Drupal::service('plugin.manager.migration')->createInstance($migration_id);
+    if ($migration) {
+      $source = $migration->getSourcePlugin();
+      $table = [];
+      foreach ($source->fields() as $machine_name => $description) {
+        $table[] = [strip_tags($description), $machine_name];
+      }
+      drush_print_table($table);
+    }
+    else {
+      $this->logger()->error(dt('Migration @id does not exist', ['@id' => $migration_id]));
+    }
+  }
+
+  /**
+   * Retrieve a list of active migrations.
+   *
+   * @param string $migration_ids
+   *  Comma-separated list of migrations - if present, return only these migrations.
+   *
+   * @return MigrationInterface[][]
+   *   An array keyed by migration group, each value containing an array of
+   *   migrations or an empty array if no migrations match the input criteria.
+   */
+  protected function migrationList($migration_ids = '') {
+    // Filter keys must match the migration configuration property name.
+    $filter['migration_group'] = drush_get_option('group') ? explode(',', drush_get_option('group')) : [];
+    $filter['migration_tags'] = drush_get_option('tag') ? explode(',', drush_get_option('tag')) : [];
+
+    $manager = \Drupal::service('plugin.manager.migration');
+    $plugins = $manager->createInstances([]);
+    $matched_migrations = [];
+
+    // Get the set of migrations that may be filtered.
+    if (empty($migration_ids)) {
+      $matched_migrations = $plugins;
+    }
+    else {
+      // Get the requested migrations.
+      $migration_ids = explode(',', Unicode::strtolower($migration_ids));
+      foreach ($plugins as $id => $migration) {
+        if (in_array(Unicode::strtolower($id), $migration_ids)) {
+          $matched_migrations[$id] = $migration;
+        }
+      }
+    }
+
+    // Do not return any migrations which fail to meet requirements.
+    /** @var \Drupal\migrate\Plugin\Migration $migration */
+    foreach ($matched_migrations as $id => $migration) {
+      if ($migration->getSourcePlugin() instanceof RequirementsInterface) {
+        try {
+          $migration->getSourcePlugin()->checkRequirements();
+        }
+        catch (RequirementsException $e) {
+          unset($matched_migrations[$id]);
+        }
+      }
+    }
+
+    // Filters the matched migrations if a group or a tag has been input.
+    if (!empty($filter['migration_group']) || !empty($filter['migration_tags'])) {
+      // Get migrations in any of the specified groups and with any of the
+      // specified tags.
+      foreach ($filter as $property => $values) {
+        if (!empty($values)) {
+          $filtered_migrations = [];
+          foreach ($values as $search_value) {
+            foreach ($matched_migrations as $id => $migration) {
+              // Cast to array because migration_tags can be an array.
+              $configured_values = (array) $migration->get($property);
+              $configured_id = (in_array($search_value, $configured_values)) ? $search_value : 'default';
+              if (empty($search_value) || $search_value == $configured_id) {
+                if (empty($migration_ids) || in_array(Unicode::strtolower($id), $migration_ids)) {
+                  $filtered_migrations[$id] = $migration;
+                }
+              }
+            }
+          }
+          $matched_migrations = $filtered_migrations;
+        }
+      }
+    }
+
+    // Sort the matched migrations by group.
+    if (!empty($matched_migrations)) {
+      foreach ($matched_migrations as $id => $migration) {
+        $configured_group_id = empty($migration->get('migration_group')) ? 'default' : $migration->get('migration_group');
+        $migrations[$configured_group_id][$id] = $migration;
+      }
+    }
+    return isset($migrations) ? $migrations : [];
+  }
+
+}