In diesem Dokument wird beschrieben, wie Sie einen Batchjob erstellen und ausführen, der ein oder mehrere externe Speichervolumes verwendet. Zu den externen Speicheroptionen gehören neue oder vorhandene Persistent Disks, neue lokale SSDs, vorhandene Cloud Storage-Buckets und ein vorhandenes Netzwerkdateisystem (NFS) wie eine Filestore-Dateifreigabe.
Unabhängig davon, ob Sie externe Speichervolumes hinzufügen, hat jede Compute Engine-VM für einen Job ein Bootlaufwerk, das Speicher für das Betriebssystem-Image und die Anweisungen des Jobs bietet. Informationen zum Konfigurieren des Bootlaufwerks für einen Job finden Sie stattdessen unter VM-Betriebssystemumgebung – Übersicht.
Hinweise
- Wenn Sie Batch noch nicht verwendet haben, lesen Sie den Abschnitt Erste Schritte mit Batch und aktivieren Sie Batch, indem Sie die Voraussetzungen für Projekte und Nutzer erfüllen.
-
Bitten Sie Ihren Administrator, Ihnen die folgenden IAM-Rollen zuzuweisen, um die Berechtigungen zu erhalten, die Sie zum Erstellen eines Jobs benötigen:
-
Batch-Job-Editor (
roles/batch.jobsEditor
) für das Projekt -
Dienstkontonutzer (
roles/iam.serviceAccountUser
) für das Dienstkonto des Jobs, das standardmäßig das Compute Engine-Standarddienstkonto ist -
Job erstellen, der einen Cloud Storage-Bucket verwendet:
Storage-Objekt-Betrachter (
roles/storage.objectViewer
) für den Bucket
Weitere Informationen zum Zuweisen von Rollen finden Sie unter Zugriff auf Projekte, Ordner und Organisationen verwalten.
Sie können die erforderlichen Berechtigungen auch über benutzerdefinierte Rollen oder andere vordefinierte Rollen erhalten.
-
Batch-Job-Editor (
Job erstellen, der Speichervolumes verwendet
Optional kann ein Job einen oder mehrere der folgenden Typen von externen Speicher-Volumes verwenden. Weitere Informationen zu allen Arten von Speichervolumes sowie zu den Unterschieden und Einschränkungen für die einzelnen Typen finden Sie in der Dokumentation zu Speicheroptionen für Compute Engine-VMs.
- Nichtflüchtiger Speicher: zonaler oder regionaler nichtflüchtiger Blockspeicher
- Lokale SSD: Temporärer Hochleistungs-Blockspeicher
- Cloud Storage-Bucket: Erschwinglicher Objektspeicher
- Network File System (NFS): verteiltes Dateisystem, das dem Network File System-Protokoll folgt, z. B. eine Filestore-Dateifreigabe>, die ein leistungsstarkes NFS ist, das auf Google Cloudgehostet wird.
Sie können einem Job die Verwendung jedes Speichervolumes erlauben, indem Sie es in die Definition des Jobs aufnehmen und seinen Bereitstellungspfad (mountPath
) in den Runnables angeben. Informationen zum Erstellen eines Jobs, der Speichervolumes verwendet, finden Sie in einem oder mehreren der folgenden Abschnitte:
- Nichtflüchtigen Speicher verwenden
- Lokale SSD verwenden
- Cloud Storage-Bucket verwenden
- Netzwerkdateisystem verwenden
Nichtflüchtigen Speicher verwenden
Für einen Job, der nichtflüchtige Speicher verwendet, gelten die folgenden Einschränkungen:
Alle nichtflüchtigen Speicher: Einschränkungen für alle nichtflüchtigen Speicher
Neue und vorhandene nichtflüchtige Speicher: Jeder nichtflüchtige Speicher in einem Job kann entweder neu sein (im Job definiert und mit dem Job erstellt) oder bereits in Ihrem Projekt vorhanden und im Job angegeben sein. Damit ein nichtflüchtiger Speicher verwendet werden kann, muss er formatiert und auf den VMs des Jobs bereitgestellt werden. Die VMs müssen sich am selben Speicherort wie der nichtflüchtige Speicher befinden. Batch hängt alle nichtflüchtigen Speicher ein, die Sie in einen Job aufnehmen, und formatiert alle neuen nichtflüchtigen Speicher. Sie müssen jedoch alle vorhandenen nichtflüchtigen Speicher, die von einem Job verwendet werden sollen, formatieren und aushängen.
Die unterstützten Standortoptionen, Formatierungsoptionen und Einbindungsoptionen variieren zwischen neuen und vorhandenen nichtflüchtigen Speichern, wie in der folgenden Tabelle beschrieben:
Neue nichtflüchtige Speicher Vorhandene nichtflüchtige Speicher Formatoptionen Der nichtflüchtige Speicher wird automatisch mit einem
ext4
-Dateisystem formatiert.Sie müssen den nichtflüchtigen Speicher formatieren, um ein
ext4
-Dateisystem zu verwenden, bevor Sie ihn für einen Job verwenden.Bereitstellungsoptionen Alle Optionen werden unterstützt.
Alle Optionen außer „Schreiben“ werden unterstützt. Dies liegt an den Einschränkungen des Modus für mehrere Autoren.
Sie müssen den nichtflüchtigen Speicher von allen VMs trennen, an die er angehängt ist, bevor Sie ihn für einen Job verwenden.
Speicherortoptionen Sie können nur zonale nichtflüchtige Speicher erstellen.
Sie können jeden beliebigen Ort für Ihren Job auswählen. Die nichtflüchtigen Speicher werden in der Zone erstellt, in der Ihr Projekt ausgeführt wird.
Sie können zonale und regionale nichtflüchtige Speicher auswählen.
Sie müssen den Standort des Jobs (oder, falls angegeben, nur die zulässigen Standorte des Jobs) auf nur Standorte festlegen, die alle persistenten Datenträger des Jobs enthalten. Bei einem zonalen nichtflüchtigen Speicher muss sich der Job beispielsweise in der Zone des Laufwerks befinden. Bei einem regionalen nichtflüchtigen Speicher muss sich der Job entweder in der Region des Laufwerks oder, wenn Zonen angegeben werden, in einer oder beiden der spezifischen Zonen befinden, in denen sich der regionale nichtflüchtige Speicher befindet.Instanzvorlagen: Wenn Sie beim Erstellen dieses Jobs eine VM-Instanzvorlage verwenden, müssen Sie alle nichtflüchtigen Speicher für diesen Job in der Instanzvorlage anhängen. Wenn Sie keine Instanzvorlage verwenden möchten, müssen Sie alle nichtflüchtigen Speicher direkt in der Jobdefinition anhängen.
Sie können einen Job erstellen, der eine persistente Festplatte verwendet, indem Sie dieGoogle Cloud Console, die gcloud CLI, die Batch API, C++, Go, Java, Node.js oder Python verwenden.
Console
Im folgenden Beispiel wird über die Google Cloud -Konsole ein Job erstellt, der ein Skript ausführt, um eine Datei von einem vorhandenen zonalen nichtflüchtigen Speicher zu lesen, der sich in der Zone us-central1-a
befindet. Im Beispielskript wird davon ausgegangen, dass für den Job ein vorhandener zonaler nichtflüchtiger Speicher vorhanden ist, der im Stammverzeichnis eine Textdatei namens example.txt
enthält.
Optional: Beispiel für einen zonalen nichtflüchtigen Speicher erstellen
Wenn Sie einen zonalen nichtflüchtigen Speicher erstellen möchten, den Sie zum Ausführen des Beispielskripts verwenden können, gehen Sie vor dem Erstellen des Jobs so vor:
Hängen Sie einen neuen, leeren nichtflüchtigen Speicher mit dem Namen
example-disk
an eine Linux-VM in der Zoneus-central1-a
an und führen Sie dann Befehle auf der VM aus, um das Laufwerk zu formatieren und bereitzustellen. Eine Anleitung finden Sie unter Nichtflüchtigen Speicher zu Instanz hinzufügen.Trennen Sie die Verbindung zur VM noch nicht.
Führen Sie die folgenden Befehle auf der VM aus, um
example.txt
auf dem nichtflüchtigen Speicher zu erstellen:Geben Sie den folgenden Befehl ein, um das aktuelle Arbeitsverzeichnis in das Stammverzeichnis des nichtflüchtigen Speichers zu ändern:
cd VM_MOUNT_PATH
Ersetzen Sie VM_MOUNT_PATH durch den Pfad zum Verzeichnis, in dem der nichtflüchtige Speicher im vorherigen Schritt auf dieser VM bereitgestellt wurde, z. B.
/mnt/disks/example-disk
.Drücken Sie
Enter
.Geben Sie den folgenden Befehl ein, um eine Datei mit dem Namen
example.txt
zu erstellen und zu definieren:cat > example.txt
Drücken Sie
Enter
.Geben Sie den Inhalt der Datei ein. Geben Sie beispielsweise
Hello world!
ein.Drücken Sie zum Speichern der Datei
Ctrl+D
(oderCommand+D
unter macOS).
Wenn Sie fertig sind, können Sie die Verbindung zur VM trennen.
Trennen Sie den nichtflüchtigen Speicher von der VM.
Wenn Sie die VM nicht mehr benötigen, können Sie sie löschen. Dadurch wird die Verbindung zum nichtflüchtigen Speicher automatisch getrennt.
Trennen Sie andernfalls den nichtflüchtigen Speicher. Eine Anleitung finden Sie unter Bootlaufwerke trennen und wieder anhängen. Trennen Sie den nichtflüchtigen Speicher
example-disk
anstelle des Bootlaufwerks der VM.
Job erstellen, der den vorhandenen zonalen nichtflüchtigen Speicher verwendet
So erstellen Sie einen Job, der vorhandene zonale nichtflüchtige Speicher verwendet, mit derGoogle Cloud -Konsole:
Rufen Sie in der Google Cloud Console die Seite Jobliste auf.
Klicken Sie auf
Erstellen. Die Seite Batchjob erstellen wird geöffnet. Im linken Bereich ist die Seite Jobdetails ausgewählt.Konfigurieren Sie die Seite Jobdetails:
Optional: Passen Sie im Feld Jobname den Jobnamen an.
Geben Sie beispielsweise
example-disk-job
ein.Konfigurieren Sie den Abschnitt Aufgabendetails:
Fügen Sie im Fenster Neues Runnable mindestens ein Script oder einen Container hinzu, damit dieser Job ausgeführt werden kann.
Wenn Sie beispielsweise ein Skript ausführen möchten, das den Inhalt einer Datei mit dem Namen
example.txt
ausgibt, die sich im Stammverzeichnis des nichtflüchtigen Speichers befindet, der von diesem Job verwendet wird, gehen Sie so vor:Klicken Sie das Kästchen Script an. Ein Textfeld wird angezeigt.
Geben Sie das folgende Skript in das Textfeld ein:
echo "Here is the content of the example.txt file in the persistent disk." cat MOUNT_PATH/example.txt
Ersetzen Sie MOUNT_PATH durch den Pfad, unter dem Sie den nichtflüchtigen Speicher für diesen Job in den VMs einhängen möchten, z. B.
/mnt/disks/example-disk
.Klicken Sie auf Fertig.
Geben Sie im Feld Anzahl der Aufgaben die Anzahl der Aufgaben für diesen Job ein.
Geben Sie beispielsweise
1
(Standardeinstellung) ein.Geben Sie im Feld Parallelität die Anzahl der Aufgaben ein, die gleichzeitig ausgeführt werden sollen.
Geben Sie beispielsweise
1
(Standardeinstellung) ein.
Konfigurieren Sie die Seite Ressourcenspezifikationen:
Klicken Sie im linken Bereich auf Ressourcenspezifikationen. Die Seite Ressourcenspezifikationen wird geöffnet.
Wählen Sie den Standort für diesen Job aus. Wenn Sie einen vorhandenen zonalen nichtflüchtigen Speicher verwenden möchten, müssen sich die VMs eines Jobs in derselben Zone befinden.
Wählen Sie im Feld Region eine Region aus.
Wenn Sie beispielsweise den zonalen nichtflüchtigen Speicher aus dem Beispiel verwenden möchten, wählen Sie
us-central1 (Iowa)
(Standardeinstellung) aus.Wählen Sie im Feld Zone eine Zone aus.
Wählen Sie beispielsweise
us-central1-a (Iowa)
aus.
Konfigurieren Sie die Seite Zusätzliche Konfigurationen:
Klicken Sie im linken Bereich auf Zusätzliche Konfigurationen. Die Seite Zusätzliche Konfigurationen wird geöffnet.
Führen Sie für jeden vorhandenen zonalen nichtflüchtigen Speicher, den Sie in diesem Job bereitstellen möchten, die folgenden Schritte aus:
Klicken Sie im Bereich Speichervolume auf Neues Volume hinzufügen. Das Fenster Neues Volume wird angezeigt.
Führen Sie im Fenster Neues Volume die folgenden Schritte aus:
Wählen Sie im Abschnitt Volume-Typ die Option Nichtflüchtiger Speicher (Standardeinstellung) aus.
Wählen Sie in der Liste Laufwerk ein vorhandenes zonales nichtflüchtiges Laufwerk aus, das Sie in diesem Job einbinden möchten. Das Laufwerk muss sich in derselben Zone wie dieser Job befinden.
Wählen Sie beispielsweise den vorhandenen zonalen nichtflüchtigen Speicher aus, den Sie vorbereitet haben. Er befindet sich in der Zone
us-central1-a
und enthält die Dateiexample.txt
.Optional: So benennen Sie diesen zonalen nichtflüchtigen Speicher um:
Wählen Sie Gerätenamen anpassen aus.
Geben Sie im Feld Gerätename den neuen Namen für Ihr Laufwerk ein.
Geben Sie im Feld Bereitstellungspfad den Bereitstellungspfad (MOUNT_PATH) für diesen nichtflüchtigen Speicher ein:
Geben Sie beispielsweise Folgendes ein:
/mnt/disks/EXISTING_PERSISTENT_DISK_NAME
Ersetzen Sie EXISTING_PERSISTENT_DISK_NAME durch den Namen des Laufwerks. Wenn Sie den zonalen nichtflüchtigen Speicher umbenannt haben, verwenden Sie den neuen Namen.
Ersetzen Sie beispielsweise EXISTING_PERSISTENT_DISK_NAME durch
example-disk
.Klicken Sie auf Fertig.
Optional: Konfigurieren Sie die anderen Felder für diesen Job.
Optional: Wenn Sie die Jobkonfiguration überprüfen möchten, klicken Sie im linken Bereich auf Vorschau.
Klicken Sie auf Erstellen.
Auf der Seite Jobdetails wird der von Ihnen erstellte Job angezeigt.
gcloud
Im folgenden Beispiel wird mit der gcloud CLI ein Job erstellt, in dem ein vorhandener und ein neuer nichtflüchtiger Speicher angehängt und bereitgestellt werden.
Der Job hat drei Aufgaben, die jeweils ein Skript ausführen, um eine Datei auf der neuen nichtflüchtigen Festplatte mit dem Namen output_task_TASK_INDEX.txt
zu erstellen, wobei TASK_INDEX der Index der einzelnen Aufgaben ist: 0, 1 und 2.
Verwenden Sie den Befehl gcloud batch jobs submit
, um einen Job zu erstellen, der nichtflüchtige Speicher verwendet.
Geben Sie in der JSON-Konfigurationsdatei des Jobs die nichtflüchtigen Speicher im Feld instances
an und stellen Sie den nichtflüchtigen Speicher im Feld volumes
bereit.
Erstellen Sie eine JSON-Datei.
Wenn Sie für diesen Job keine Instanzvorlage verwenden, erstellen Sie eine JSON-Datei mit folgendem Inhalt:
{ "allocationPolicy": { "instances": [ { "policy": { "disks": [ { "deviceName": "EXISTING_PERSISTENT_DISK_NAME", "existingDisk": "projects/PROJECT_ID/EXISTING_PERSISTENT_DISK_LOCATION/disks/EXISTING_PERSISTENT_DISK_NAME" }, { "newDisk": { "sizeGb": NEW_PERSISTENT_DISK_SIZE, "type": "NEW_PERSISTENT_DISK_TYPE" }, "deviceName": "NEW_PERSISTENT_DISK_NAME" } ] } } ], "location": { "allowedLocations": [ "EXISTING_PERSISTENT_DISK_LOCATION" ] } }, "taskGroups": [ { "taskSpec": { "runnables": [ { "script": { "text": "echo Hello world from task ${BATCH_TASK_INDEX}. >> /mnt/disks/NEW_PERSISTENT_DISK_NAME/output_task_${BATCH_TASK_INDEX}.txt" } } ], "volumes": [ { "deviceName": "NEW_PERSISTENT_DISK_NAME", "mountPath": "/mnt/disks/NEW_PERSISTENT_DISK_NAME", "mountOptions": "rw,async" }, { "deviceName": "EXISTING_PERSISTENT_DISK_NAME", "mountPath": "/mnt/disks/EXISTING_PERSISTENT_DISK_NAME" } ] }, "taskCount":3 } ], "logsPolicy": { "destination": "CLOUD_LOGGING" } }
Ersetzen Sie Folgendes:
PROJECT_ID
: die Projekt-ID Ihres Projekts.EXISTING_PERSISTENT_DISK_NAME
: der Name eines vorhandenen nichtflüchtigen Speichers.EXISTING_PERSISTENT_DISK_LOCATION
: der Speicherort eines vorhandenen nichtflüchtigen Speichers. Für jeden vorhandenen zonalen nichtflüchtigen Speicher muss der Standort des Jobs die Zone des Laufwerks sein. Für jeden vorhandenen regionalen nichtflüchtigen Speicher muss der Standort des Jobs entweder die Region des Laufwerks oder, wenn Zonen angegeben werden, eine oder beide der spezifischen Zonen sein, in denen sich der regionale nichtflüchtige Speicher befindet. Wenn Sie keine vorhandenen persistenten Datenträger angeben, können Sie einen beliebigen Standort auswählen. Weitere Informationen zum FeldallowedLocations
NEW_PERSISTENT_DISK_SIZE
: die Größe des neuen nichtflüchtigen Speichers in GB. Die zulässigen Größen hängen vom Typ des nichtflüchtigen Speichers ab. Das Minimum beträgt jedoch oft 10 GB (10
) und das Maximum oft 64 TB (64000
).NEW_PERSISTENT_DISK_TYPE
: der Laufwerkstyp des neuen nichtflüchtigen Speichers, entwederpd-standard
,pd-balanced
,pd-ssd
oderpd-extreme
. Der Standardlaufwerkstyp für nichtflüchtige Speicher, die nicht als Bootlaufwerk verwendet werden, istpd-standard
.NEW_PERSISTENT_DISK_NAME
: Name des neuen nichtflüchtigen Speichers.
Wenn Sie eine VM-Instanzvorlage für diesen Job verwenden, erstellen Sie eine JSON-Datei wie zuvor, ersetzen Sie jedoch das
instances
-Feld durch Folgendes:"instances": [ { "instanceTemplate": "INSTANCE_TEMPLATE_NAME" } ],
Dabei ist
INSTANCE_TEMPLATE_NAME
der Name der Instanzvorlage für diesen Job. Für einen Job, der nichtflüchtige Speicher verwendet, müssen in dieser Instanzvorlage die nichtflüchtigen Speicher definiert und angehängt werden, die der Job verwenden soll. In diesem Beispiel muss in der Vorlage ein neuer nichtflüchtiger Speicher mit dem NamenNEW_PERSISTENT_DISK_NAME
definiert und angehängt werden. Außerdem muss ein vorhandener nichtflüchtiger Speicher mit dem NamenEXISTING_PERSISTENT_DISK_NAME
angehängt werden.
Führen Sie dazu diesen Befehl aus:
gcloud batch jobs submit JOB_NAME \ --location LOCATION \ --config JSON_CONFIGURATION_FILE
Ersetzen Sie Folgendes:
JOB_NAME
: Der Name des Jobs.LOCATION
: Der Standort des Jobs.JSON_CONFIGURATION_FILE
: der Pfad zu einer JSON-Datei mit den Konfigurationsdetails des Jobs.
API
Im folgenden Beispiel wird mit der Batch API ein Job erstellt, mit dem ein vorhandener nichtflüchtiger Speicher und ein neuer nichtflüchtiger Speicher angehängt und bereitgestellt werden. Der Job hat drei Aufgaben, die jeweils ein Skript ausführen, um eine Datei auf der neuen nichtflüchtigen Festplatte mit dem Namen output_task_TASK_INDEX.txt
zu erstellen, wobei TASK_INDEX der Index der einzelnen Aufgaben ist: 0, 1 und 2.
Wenn Sie mit der Batch API einen Job erstellen möchten, der nichtflüchtige Speicher verwendet, verwenden Sie die jobs.create
-Methode.
Geben Sie in der Anfrage die nichtflüchtigen Speicher im Feld instances
an und stellen Sie den nichtflüchtigen Speicher im Feld volumes
bereit.
Wenn Sie für diesen Job keine Instanzvorlage verwenden, stellen Sie die folgende Anfrage:
POST https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs?job_id=JOB_NAME { "allocationPolicy": { "instances": [ { "policy": { "disks": [ { "deviceName": "EXISTING_PERSISTENT_DISK_NAME", "existingDisk": "projects/PROJECT_ID/EXISTING_PERSISTENT_DISK_LOCATION/disks/EXISTING_PERSISTENT_DISK_NAME" }, { "newDisk": { "sizeGb": NEW_PERSISTENT_DISK_SIZE, "type": "NEW_PERSISTENT_DISK_TYPE" }, "deviceName": "NEW_PERSISTENT_DISK_NAME" } ] } } ], "location": { "allowedLocations": [ "EXISTING_PERSISTENT_DISK_LOCATION" ] } }, "taskGroups": [ { "taskSpec": { "runnables": [ { "script": { "text": "echo Hello world from task ${BATCH_TASK_INDEX}. >> /mnt/disks/NEW_PERSISTENT_DISK_NAME/output_task_${BATCH_TASK_INDEX}.txt" } } ], "volumes": [ { "deviceName": "NEW_PERSISTENT_DISK_NAME", "mountPath": "/mnt/disks/NEW_PERSISTENT_DISK_NAME", "mountOptions": "rw,async" }, { "deviceName": "EXISTING_PERSISTENT_DISK_NAME", "mountPath": "/mnt/disks/EXISTING_PERSISTENT_DISK_NAME" } ] }, "taskCount":3 } ], "logsPolicy": { "destination": "CLOUD_LOGGING" } }
Ersetzen Sie Folgendes:
PROJECT_ID
: die Projekt-ID Ihres Projekts.LOCATION
: Der Standort des Jobs.JOB_NAME
: Der Name des Jobs.EXISTING_PERSISTENT_DISK_NAME
: der Name eines vorhandenen nichtflüchtigen Speichers.EXISTING_PERSISTENT_DISK_LOCATION
: der Speicherort eines vorhandenen nichtflüchtigen Speichers. Für jeden vorhandenen zonalen nichtflüchtigen Speicher muss der Standort des Jobs die Zone des Laufwerks sein. Für jeden vorhandenen regionalen nichtflüchtigen Speicher muss der Standort des Jobs entweder die Region des Laufwerks oder, wenn Zonen angegeben werden, eine oder beide der spezifischen Zonen sein, in denen sich der regionale nichtflüchtige Speicher befindet. Wenn Sie keine vorhandenen nichtflüchtigen Speicher angeben, können Sie einen beliebigen Speicherort auswählen. Weitere Informationen zum FeldallowedLocations
NEW_PERSISTENT_DISK_SIZE
: die Größe des neuen nichtflüchtigen Speichers in GB. Die zulässigen Größen hängen vom Typ des nichtflüchtigen Speichers ab. Das Minimum beträgt jedoch oft 10 GB (10
) und das Maximum oft 64 TB (64000
).NEW_PERSISTENT_DISK_TYPE
: der Laufwerkstyp des neuen nichtflüchtigen Speichers, entwederpd-standard
,pd-balanced
,pd-ssd
oderpd-extreme
. Der Standardlaufwerkstyp für nichtflüchtige Speicher, die nicht als Bootlaufwerk verwendet werden, istpd-standard
.NEW_PERSISTENT_DISK_NAME
: Name des neuen nichtflüchtigen Speichers.
Wenn Sie eine VM-Instanzvorlage für diesen Job verwenden, erstellen Sie eine JSON-Datei wie zuvor, ersetzen Sie jedoch das
instances
-Feld durch Folgendes:"instances": [ { "instanceTemplate": "INSTANCE_TEMPLATE_NAME" } ], ...
Dabei ist
INSTANCE_TEMPLATE_NAME
der Name der Instanzvorlage für diesen Job. Für einen Job, der nichtflüchtige Speicher verwendet, müssen in dieser Instanzvorlage die nichtflüchtigen Speicher definiert und angehängt werden, die der Job verwenden soll. In diesem Beispiel muss in der Vorlage ein neuer nichtflüchtiger Speicher mit dem NamenNEW_PERSISTENT_DISK_NAME
definiert und angehängt werden. Außerdem muss ein vorhandener nichtflüchtiger Speicher mit dem NamenEXISTING_PERSISTENT_DISK_NAME
angehängt werden.
C++
Wenn Sie einen Batch-Job erstellen möchten, der neue oder vorhandene persistenten Datenträger mit den Cloud-Clientbibliotheken für C++ verwendet, verwenden Sie die CreateJob
-Funktion und fügen Sie Folgendes ein:
- Wenn Sie nichtflüchtige Speicher an die VMs für einen Job anhängen möchten, fügen Sie eines der folgenden Elemente ein:
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, verwenden Sie die Methode
set_remote_path
. - Wenn Sie für diesen Job eine VM-Instanzvorlage verwenden, verwenden Sie die Methode
set_instance_template
.
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, verwenden Sie die Methode
- Wenn Sie die nichtflüchtigen Speicher für den Job einbinden möchten, verwenden Sie das Feld
volumes
mit den FelderndeviceName
undmountPath
. Verwenden Sie für neue nichtflüchtige Speicher auch das FeldmountOptions
, um das Schreiben zu aktivieren.
Ein Codebeispiel für einen ähnlichen Anwendungsfall finden Sie unter Cloud Storage-Bucket verwenden.
Go
Wenn Sie einen Batchjob erstellen möchten, der neue oder vorhandene persistenten Datenträger mit den Cloud-Clientbibliotheken für Go verwendet, verwenden Sie die CreateJob
-Funktion und fügen Sie Folgendes ein:
- Wenn Sie nichtflüchtige Speicher an die VMs für einen Job anhängen möchten, fügen Sie eines der folgenden Elemente ein:
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, geben Sie den Typ
AllocationPolicy_AttachedDisk
an. - Wenn Sie für diesen Job eine VM-Instanzvorlage verwenden, geben Sie den Typ
AllocationPolicy_InstancePolicyOrTemplate_InstanceTemplate
an.
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, geben Sie den Typ
- Wenn Sie die nichtflüchtigen Speicher für den Job bereitstellen möchten, verwenden Sie den Typ
Volume
mit dem TypVolume_DeviceName
und dem FeldMountPath
. Verwenden Sie für neue nichtflüchtige Speicher auch das FeldMountOptions
, um das Schreiben zu aktivieren.
Java
Wenn Sie einen Batchjob erstellen möchten, der neue oder vorhandene persistenten Datenträger mit den Cloud-Clientbibliotheken für Java verwendet, verwenden Sie die CreateJobRequest
-Klasse und fügen Sie Folgendes ein:
- Wenn Sie nichtflüchtige Speicher an die VMs für einen Job anhängen möchten, fügen Sie eines der folgenden Elemente ein:
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, fügen Sie die Methode
setDisks
ein. - Wenn Sie für diesen Job eine VM-Instanzvorlage verwenden, fügen Sie die Methode
setInstanceTemplate
ein.
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, fügen Sie die Methode
- Verwenden Sie die Klasse
Volume
mit der MethodesetDeviceName
und der MethodesetMountPath
, um die nichtflüchtigen Speicher im Job bereitzustellen. Verwenden Sie für neue nichtflüchtige Speicher auch die MethodesetMountOptions
, um das Schreiben zu aktivieren.
Verwenden Sie beispielsweise das folgende Codebeispiel:
Node.js
Wenn Sie einen Batchjob erstellen möchten, der neue oder vorhandene nichtflüchtige Datenträger mit den Cloud-Clientbibliotheken für Node.js verwendet, verwenden Sie die createJob
-Methode und fügen Sie Folgendes ein:
- Wenn Sie nichtflüchtige Speicher an die VMs für einen Job anhängen möchten, fügen Sie eines der folgenden Elemente ein:
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, fügen Sie die
AllocationPolicy.AttachedDisk
-Klasse ein. - Wenn Sie für diesen Job eine VM-Instanzvorlage verwenden, fügen Sie die Property
instanceTemplate
ein.
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, fügen Sie die
- Verwenden Sie die Klasse
Volume
mit dem AttributdeviceName
und dem AttributmountPath
, um die nichtflüchtigen Speicher in den Job einzubinden. Verwenden Sie für neue nichtflüchtige Speicher auch das AttributmountOptions
, um das Schreiben zu aktivieren.
Python
Wenn Sie einen Batch-Job erstellen möchten, der neue oder vorhandene persistenten Datenträger mit den Cloud-Clientbibliotheken für Python verwendet, verwenden Sie die CreateJob
-Funktion und fügen Sie Folgendes ein:
- Wenn Sie nichtflüchtige Speicher an die VMs für einen Job anhängen möchten, fügen Sie eines der folgenden Elemente ein:
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, fügen Sie die
AttachedDisk
-Klasse ein. - Wenn Sie für diesen Job eine VM-Instanzvorlage verwenden, fügen Sie das Attribut
instance_template
ein.
- Wenn Sie für diesen Job keine VM-Instanzvorlage verwenden, fügen Sie die
- Wenn Sie die nichtflüchtigen Speicher im Job einbinden möchten, verwenden Sie die Klasse
Volume
mit dem Attributdevice_name
und dem Attributmount_path
. Verwenden Sie für neue nichtflüchtige Speicher auch das Attributmount_options
, um das Schreiben zu aktivieren.
Verwenden Sie beispielsweise das folgende Codebeispiel:
Lokale SSD verwenden
Für Jobs, die lokale SSDs verwenden, gelten die folgenden Einschränkungen:
- Alle lokalen SSDs: Einschränkungen für alle lokalen SSDs
- Instanzvorlagen: Wenn Sie beim Erstellen dieses Jobs eine VM-Instanzvorlage angeben, müssen Sie alle nichtflüchtigen Speicher für diesen Job in der Instanzvorlage anhängen. Wenn Sie keine Instanzvorlage verwenden möchten, müssen Sie alle nichtflüchtigen Speicher direkt in der Jobdefinition anhängen.
Sie können einen Job erstellen, der eine lokale SSD verwendet, indem Sie die gcloud CLI, die Batch API, Java oder Python verwenden.
Im folgenden Beispiel wird beschrieben, wie Sie einen Job erstellen, mit dem eine lokale SSD erstellt, angehängt und bereitgestellt wird. Der Job hat auch drei Aufgaben, die jeweils ein Skript ausführen, um eine Datei auf der lokalen SSD mit dem Namen output_task_TASK_INDEX.txt
zu erstellen, wobei TASK_INDEX
der Index der einzelnen Aufgaben ist: 0
, 1
und 2
.
gcloud
Verwenden Sie den gcloud CLI gcloud batch jobs submit
, um einen Job zu erstellen, der lokale SSDs verwendet.
Erstellen und hängen Sie die lokalen SSDs in der JSON-Konfigurationsdatei des Jobs im Feld instances
an und stellen Sie die lokalen SSDs im Feld volumes
bereit.
Erstellen Sie eine JSON-Datei.
Wenn Sie für diesen Job keine Instanzvorlage verwenden, erstellen Sie eine JSON-Datei mit folgendem Inhalt:
{ "allocationPolicy": { "instances": [ { "policy": { "machineType": MACHINE_TYPE, "disks": [ { "newDisk": { "sizeGb": LOCAL_SSD_SIZE, "type": "local-ssd" }, "deviceName": "LOCAL_SSD_NAME" } ] } } ] }, "taskGroups": [ { "taskSpec": { "runnables": [ { "script": { "text": "echo Hello world from task ${BATCH_TASK_INDEX}. >> /mnt/disks/LOCAL_SSD_NAME/output_task_${BATCH_TASK_INDEX}.txt" } } ], "volumes": [ { "deviceName": "LOCAL_SSD_NAME", "mountPath": "/mnt/disks/LOCAL_SSD_NAME", "mountOptions": "rw,async" } ] }, "taskCount":3 } ], "logsPolicy": { "destination": "CLOUD_LOGGING" } }
Ersetzen Sie Folgendes:
MACHINE_TYPE
: Der Maschinentyp der VMs des Jobs. Dieser kann vordefiniert oder benutzerdefiniert sein. Die zulässige Anzahl lokaler SSDs hängt vom Maschinentyp der VMs für Ihren Job ab.LOCAL_SSD_NAME
: Der Name einer lokalen SSD, die für diesen Job erstellt wurde.LOCAL_SSD_SIZE
: Die Größe aller lokalen SSDs in GB. Jede lokale SSD ist 375 GB groß. Dieser Wert muss also ein Vielfaches von375
GB sein. Wenn Sie beispielsweise zwei lokale SSDs verwenden, legen Sie diesen Wert auf750
GB fest.
Wenn Sie eine VM-Instanzvorlage für diesen Job verwenden, erstellen Sie eine JSON-Datei wie zuvor, ersetzen Sie jedoch das
instances
-Feld durch Folgendes:"instances": [ { "instanceTemplate": "INSTANCE_TEMPLATE_NAME" } ],
Dabei ist
INSTANCE_TEMPLATE_NAME
der Name der Instanzvorlage für diesen Job. Für einen Job, der lokale SSDs verwendet, müssen in dieser Instanzvorlage die lokalen SSDs definiert und angehängt werden, die für den Job verwendet werden sollen. In diesem Beispiel muss in der Vorlage eine lokale SSD mit dem NamenLOCAL_SSD_NAME
definiert und angehängt werden.
Führen Sie dazu diesen Befehl aus:
gcloud batch jobs submit JOB_NAME \ --location LOCATION \ --config JSON_CONFIGURATION_FILE
Ersetzen Sie Folgendes:
JOB_NAME
: Der Name des Jobs.LOCATION
: Der Standort des Jobs.JSON_CONFIGURATION_FILE
: der Pfad zu einer JSON-Datei mit den Konfigurationsdetails des Jobs.
API
Wenn Sie mit der Batch API einen Job erstellen möchten, der lokale SSDs verwendet, nutzen Sie die jobs.create
-Methode.
Erstellen und hängen Sie die lokalen SSDs in der Anfrage im Feld instances
an und stellen Sie sie im Feld volumes
bereit.
Wenn Sie für diesen Job keine Instanzvorlage verwenden, stellen Sie die folgende Anfrage:
POST https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs?job_id=JOB_NAME { "allocationPolicy": { "instances": [ { "policy": { "machineType": MACHINE_TYPE, "disks": [ { "newDisk": { "sizeGb": LOCAL_SSD_SIZE, "type": "local-ssd" }, "deviceName": "LOCAL_SSD_NAME" } ] } } ] }, "taskGroups": [ { "taskSpec": { "runnables": [ { "script": { "text": "echo Hello world from task ${BATCH_TASK_INDEX}. >> /mnt/disks/LOCAL_SSD_NAME/output_task_${BATCH_TASK_INDEX}.txt" } } ], "volumes": [ { "deviceName": "LOCAL_SSD_NAME", "mountPath": "/mnt/disks/LOCAL_SSD_NAME", "mountOptions": "rw,async" } ] }, "taskCount":3 } ], "logsPolicy": { "destination": "CLOUD_LOGGING" } }
Ersetzen Sie Folgendes:
PROJECT_ID
: die Projekt-ID Ihres Projekts.LOCATION
: Der Standort des Jobs.JOB_NAME
: Der Name des Jobs.MACHINE_TYPE
: Der Maschinentyp der VMs des Jobs. Dieser kann vordefiniert oder benutzerdefiniert sein. Die zulässige Anzahl lokaler SSDs hängt vom Maschinentyp der VMs für Ihren Job ab.LOCAL_SSD_NAME
: Der Name einer lokalen SSD, die für diesen Job erstellt wurde.LOCAL_SSD_SIZE
: Die Größe aller lokalen SSDs in GB. Jede lokale SSD ist 375 GB groß. Dieser Wert muss also ein Vielfaches von375
GB sein. Wenn Sie beispielsweise zwei lokale SSDs verwenden, legen Sie diesen Wert auf750
GB fest.
Wenn Sie eine VM-Instanzvorlage für diesen Job verwenden, erstellen Sie eine JSON-Datei wie zuvor, ersetzen Sie jedoch das
instances
-Feld durch Folgendes:"instances": [ { "instanceTemplate": "INSTANCE_TEMPLATE_NAME" } ], ...
Dabei ist
INSTANCE_TEMPLATE_NAME
der Name der Instanzvorlage für diesen Job. Für einen Job, der lokale SSDs verwendet, müssen in dieser Instanzvorlage die lokalen SSDs definiert und angehängt werden, die für den Job verwendet werden sollen. In diesem Beispiel muss in der Vorlage eine lokale SSD mit dem NamenLOCAL_SSD_NAME
definiert und angehängt werden.
Go
Java
Node.js
Python
Cloud Storage-Bucket verwenden
Wenn Sie einen Job erstellen möchten, der einen vorhandenen Cloud Storage-Bucket verwendet, wählen Sie eine der folgenden Methoden aus:
- Empfohlen: Stellen Sie einen Bucket direkt für die VMs Ihres Jobs bereit, indem Sie den Bucket in der Definition des Jobs angeben, wie in diesem Abschnitt gezeigt. Wenn der Job ausgeführt wird, wird der Bucket automatisch mit Cloud Storage FUSE auf den VMs für Ihren Job bereitgestellt.
- Erstellen Sie einen Job mit Aufgaben, die direkt auf einen Cloud Storage-Bucket zugreifen. Verwenden Sie dazu die gcloud CLI oder Clientbibliotheken für die Cloud Storage API. Informationen zum direkten Zugriff auf einen Cloud Storage-Bucket über eine VM finden Sie in der Compute Engine-Dokumentation unter Daten in Cloud Storage-Buckets schreiben und daraus lesen.
Bevor Sie einen Job erstellen, der einen Bucket verwendet, müssen Sie einen Bucket erstellen oder einen vorhandenen Bucket auswählen. Weitere Informationen finden Sie unter Buckets erstellen und Buckets auflisten.
Sie können einen Job erstellen, der einen Cloud Storage-Bucket verwendet, indem Sie dieGoogle Cloud Console, die gcloud CLI, die Batch API, C++, Go, Java, Node.js oder Python verwenden.
Im folgenden Beispiel wird beschrieben, wie Sie einen Job erstellen, der einen Cloud Storage-Bucket einbindet. Der Job hat auch drei Aufgaben, bei denen jeweils ein Skript ausgeführt wird, um eine Datei im Bucket mit dem Namen output_task_TASK_INDEX.txt
zu erstellen, wobei TASK_INDEX
der Index der einzelnen Aufgaben ist: 0
, 1
und 2
.
Console
So erstellen Sie einen Job, der einen Cloud Storage-Bucket verwendet, mit derGoogle Cloud Console:
Rufen Sie in der Google Cloud Console die Seite Jobliste auf.
Klicken Sie auf
Erstellen. Die Seite Batchjob erstellen wird geöffnet. Im linken Bereich ist die Seite Jobdetails ausgewählt.Konfigurieren Sie die Seite Jobdetails:
Optional: Passen Sie im Feld Jobname den Jobnamen an.
Geben Sie beispielsweise
example-bucket-job
ein.Konfigurieren Sie den Abschnitt Aufgabendetails:
Fügen Sie im Fenster Neues Runnable mindestens ein Script oder einen Container hinzu, damit dieser Job ausgeführt werden kann.
Führen Sie dazu z. B. folgende Schritte aus:
Klicken Sie das Kästchen Script an. Ein Textfeld wird angezeigt.
Geben Sie das folgende Skript in das Textfeld ein:
echo Hello world from task ${BATCH_TASK_INDEX}. >> MOUNT_PATH/output_task_${BATCH_TASK_INDEX}.txt
Ersetzen Sie MOUNT_PATH durch den Mount-Pfad, den die Runnables dieses Jobs für den Zugriff auf einen vorhandenen Cloud Storage-Bucket verwenden. Der Pfad muss mit
/mnt/disks/
beginnen, gefolgt von einem Verzeichnis oder Pfad Ihrer Wahl. Wenn Sie diesen Bucket beispielsweise mit einem Verzeichnis namensmy-bucket
darstellen möchten, legen Sie den Mount-Pfad auf/mnt/disks/my-bucket
fest.Klicken Sie auf Fertig.
Geben Sie im Feld Anzahl der Aufgaben die Anzahl der Aufgaben für diesen Job ein.
Geben Sie beispielsweise
3
ein.Geben Sie im Feld Parallelität die Anzahl der Aufgaben ein, die gleichzeitig ausgeführt werden sollen.
Geben Sie beispielsweise
1
(Standardeinstellung) ein.
Konfigurieren Sie die Seite Zusätzliche Konfigurationen:
Klicken Sie im linken Bereich auf Zusätzliche Konfigurationen. Die Seite Zusätzliche Konfigurationen wird geöffnet.
Führen Sie für jeden Cloud Storage-Bucket, den Sie für diesen Job bereitstellen möchten, die folgenden Schritte aus:
Klicken Sie im Bereich Speichervolume auf Neues Volume hinzufügen. Das Fenster Neues Volume wird angezeigt.
Führen Sie im Fenster Neues Volume die folgenden Schritte aus:
Wählen Sie im Abschnitt Volume-Typ die Option Cloud Storage-Bucket aus.
Geben Sie im Feld Name des Storage-Buckets den Namen eines vorhandenen Buckets ein.
Geben Sie beispielsweise den Bucket ein, den Sie im ausführbaren Teil dieses Jobs angegeben haben.
Geben Sie im Feld Bereitstellungspfad den Bereitstellungspfad des Buckets (MOUNT_PATH) ein, den Sie im ausführbaren Code angegeben haben.
Klicken Sie auf Fertig.
Optional: Konfigurieren Sie die anderen Felder für diesen Job.
Optional: Wenn Sie die Jobkonfiguration überprüfen möchten, klicken Sie im linken Bereich auf Vorschau.
Klicken Sie auf Erstellen.
Auf der Seite Jobdetails wird der von Ihnen erstellte Job angezeigt.
gcloud
Verwenden Sie den gcloud batch jobs submit
-Befehl, um einen Job zu erstellen, der einen Cloud Storage-Bucket verwendet.
Hängen Sie den Bucket in der JSON-Konfigurationsdatei des Jobs im Feld volumes
ein.
So erstellen Sie beispielsweise einen Job, der Dateien in Cloud Storage ausgibt:
Erstellen Sie eine package.json-Datei mit folgendem Inhalt:
{ "taskGroups": [ { "taskSpec": { "runnables": [ { "script": { "text": "echo Hello world from task ${BATCH_TASK_INDEX}. >> MOUNT_PATH/output_task_${BATCH_TASK_INDEX}.txt" } } ], "volumes": [ { "gcs": { "remotePath": "BUCKET_PATH" }, "mountPath": "MOUNT_PATH" } ] }, "taskCount": 3 } ], "logsPolicy": { "destination": "CLOUD_LOGGING" } }
Ersetzen Sie Folgendes:
BUCKET_PATH
: Der Pfad des Bucket-Verzeichnisses, auf das dieser Job zugreifen soll. Er muss mit dem Namen des Buckets beginnen. Für einen Bucket mit dem NamenBUCKET_NAME
steht der PfadBUCKET_NAME
beispielsweise für das Stammverzeichnis des Buckets und der PfadBUCKET_NAME/subdirectory
für das Unterverzeichnissubdirectory
.MOUNT_PATH
: Der Mount-Pfad, den die ausführbaren Dateien des Jobs verwenden, um auf diesen Bucket zuzugreifen. Der Pfad muss mit/mnt/disks/
beginnen, gefolgt von einem Verzeichnis oder Pfad Ihrer Wahl. Wenn Sie diesen Bucket beispielsweise mit einem Verzeichnis namensmy-bucket
darstellen möchten, legen Sie den Bereitstellungspfad auf/mnt/disks/my-bucket
fest.
Führen Sie dazu diesen Befehl aus:
gcloud batch jobs submit JOB_NAME \ --location LOCATION \ --config JSON_CONFIGURATION_FILE
Ersetzen Sie Folgendes:
JOB_NAME
: Der Name des Jobs.LOCATION
: Der Standort des Jobs.JSON_CONFIGURATION_FILE
: der Pfad zu einer JSON-Datei mit den Konfigurationsdetails des Jobs.
API
Wenn Sie einen Job erstellen möchten, der einen Cloud Storage-Bucket mit der Batch API verwendet, verwenden Sie die jobs.create
-Methode und hängen Sie den Bucket im Feld volumes
ein.
POST https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs?job_id=JOB_NAME
{
"taskGroups": [
{
"taskSpec": {
"runnables": [
{
"script": {
"text": "echo Hello world from task ${BATCH_TASK_INDEX}. >> MOUNT_PATH/output_task_${BATCH_TASK_INDEX}.txt"
}
}
],
"volumes": [
{
"gcs": {
"remotePath": "BUCKET_PATH"
},
"mountPath": "MOUNT_PATH"
}
]
},
"taskCount": 3
}
],
"logsPolicy": {
"destination": "CLOUD_LOGGING"
}
}
Ersetzen Sie Folgendes:
PROJECT_ID
: die Projekt-ID Ihres Projekts.LOCATION
: Der Standort des Jobs.JOB_NAME
: Der Name des Jobs.BUCKET_PATH
: Der Pfad des Bucket-Verzeichnisses, auf das dieser Job zugreifen soll. Er muss mit dem Namen des Buckets beginnen. Für einen Bucket mit dem NamenBUCKET_NAME
stellt der PfadBUCKET_NAME
beispielsweise das Stammverzeichnis des Buckets und der PfadBUCKET_NAME/subdirectory
das Unterverzeichnissubdirectory
dar.MOUNT_PATH
: Der Mount-Pfad, den die ausführbaren Dateien des Jobs verwenden, um auf diesen Bucket zuzugreifen. Der Pfad muss mit/mnt/disks/
beginnen, gefolgt von einem Verzeichnis oder Pfad Ihrer Wahl. Wenn Sie diesen Bucket beispielsweise mit einem Verzeichnis namensmy-bucket
darstellen möchten, legen Sie den Bereitstellungspfad auf/mnt/disks/my-bucket
fest.
C++
C++
Weitere Informationen finden Sie in der Referenzdokumentation zur Batch C++ API.
Richten Sie die Standardanmeldedaten für Anwendungen ein, um sich bei Batch zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Go
Go
Weitere Informationen finden Sie in der Referenzdokumentation zur Batch Go API.
Richten Sie die Standardanmeldedaten für Anwendungen ein, um sich bei Batch zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Java
Java
Weitere Informationen finden Sie in der Referenzdokumentation zur Batch Java API.
Richten Sie die Standardanmeldedaten für Anwendungen ein, um sich bei Batch zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Node.js
Node.js
Weitere Informationen finden Sie in der Referenzdokumentation zur Batch Node.js API.
Richten Sie die Standardanmeldedaten für Anwendungen ein, um sich bei Batch zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Python
Python
Weitere Informationen finden Sie in der Referenzdokumentation zur Batch Python API.
Richten Sie die Standardanmeldedaten für Anwendungen ein, um sich bei Batch zu authentifizieren. Weitere Informationen finden Sie unter Authentifizierung für eine lokale Entwicklungsumgebung einrichten.
Netzwerkdateisystem verwenden
Sie können einen Job erstellen, der ein vorhandenes Netzwerkdateisystem (NFS) wie eine Filestore-Dateifreigabe verwendet, indem Sie die Google Cloud Console, die gcloud CLI oder die Batch API verwenden.
Bevor Sie einen Job erstellen, der ein NFS verwendet, müssen Sie dafür sorgen, dass die Firewall Ihres Netzwerks richtig konfiguriert ist, um Traffic zwischen den VMs Ihres Jobs und dem NFS zuzulassen. Weitere Informationen finden Sie unter Firewallregeln für Filestore konfigurieren.
Im folgenden Beispiel wird beschrieben, wie Sie einen Job erstellen, in dem ein NFS angegeben und eingebunden wird. Der Job hat auch drei Aufgaben, die jeweils ein Skript ausführen, um eine Datei im NFS mit dem Namen output_task_TASK_INDEX.txt
zu erstellen, wobei TASK_INDEX
der Index jeder Aufgabe ist: 0
, 1
und 2
.
Console
So erstellen Sie einen Job, der ein NFS verwendet, mit der Google Cloud -Konsole:
Rufen Sie in der Google Cloud Console die Seite Jobliste auf.
Klicken Sie auf
Erstellen. Die Seite Batchjob erstellen wird geöffnet. Im linken Bereich ist die Seite Jobdetails ausgewählt.Konfigurieren Sie die Seite Jobdetails:
Optional: Passen Sie im Feld Jobname den Jobnamen an.
Geben Sie beispielsweise
example-nfs-job
ein.Konfigurieren Sie den Abschnitt Aufgabendetails:
Fügen Sie im Fenster Neues Runnable mindestens ein Script oder einen Container hinzu, damit dieser Job ausgeführt werden kann.
Führen Sie dazu z. B. folgende Schritte aus:
Klicken Sie das Kästchen Script an. Ein Textfeld wird angezeigt.
Geben Sie das folgende Skript in das Textfeld ein:
echo Hello world from task ${BATCH_TASK_INDEX}. >> MOUNT_PATH/output_task_${BATCH_TASK_INDEX}.txt
Ersetzen Sie MOUNT_PATH durch den Mount-Pfad, den die ausführbare Datei des Jobs für den Zugriff auf dieses NFS verwendet. Der Pfad muss mit
/mnt/disks/
beginnen, gefolgt von einem Verzeichnis oder Pfad Ihrer Wahl. Wenn Sie dieses NFS beispielsweise mit einem Verzeichnis namensmy-nfs
darstellen möchten, legen Sie den Bereitstellungspfad auf/mnt/disks/my-nfs
fest.Klicken Sie auf Fertig.
Geben Sie im Feld Anzahl der Aufgaben die Anzahl der Aufgaben für diesen Job ein.
Geben Sie beispielsweise
3
ein.Geben Sie im Feld Parallelität die Anzahl der Aufgaben ein, die gleichzeitig ausgeführt werden sollen.
Geben Sie beispielsweise
1
(Standardeinstellung) ein.
Konfigurieren Sie die Seite Zusätzliche Konfigurationen:
Klicken Sie im linken Bereich auf Zusätzliche Konfigurationen. Die Seite Zusätzliche Konfigurationen wird geöffnet.
Führen Sie für jeden Cloud Storage-Bucket, den Sie für diesen Job bereitstellen möchten, die folgenden Schritte aus:
Klicken Sie im Bereich Speichervolume auf Neues Volume hinzufügen. Das Fenster Neues Volume wird angezeigt.
Führen Sie im Fenster Neues Volume die folgenden Schritte aus:
Wählen Sie im Bereich Volume-Typ die Option Network File System aus.
Geben Sie im Feld File server die IP-Adresse des Servers ein, auf dem sich das in diesem Job angegebene ausführbare NFS befindet.
Wenn Ihr NFS beispielsweise eine Filestore-Dateifreigabe ist, geben Sie die IP-Adresse der Filestore-Instanz an, die Sie durch Beschreiben der Filestore-Instanz abrufen können.
Geben Sie im Feld Remote-Pfad einen Pfad ein, über den auf das NFS zugegriffen werden kann, das Sie im vorherigen Schritt angegeben haben.
Der Pfad des NFS-Verzeichnisses muss mit einem
/
beginnen, gefolgt vom Stammverzeichnis des NFS.Geben Sie im Feld Bereitstellungspfad den Bereitstellungspfad zum NFS (MOUNT_PATH) ein, den Sie im vorherigen Schritt angegeben haben.
Klicken Sie auf Fertig.
Optional: Konfigurieren Sie die anderen Felder für diesen Job.
Optional: Wenn Sie die Jobkonfiguration überprüfen möchten, klicken Sie im linken Bereich auf Vorschau.
Klicken Sie auf Erstellen.
Auf der Seite Jobdetails wird der von Ihnen erstellte Job angezeigt.
gcloud
Verwenden Sie den gcloud CLI gcloud batch jobs submit
, um einen Job zu erstellen, der ein NFS verwendet.
Hängen Sie in der JSON-Konfigurationsdatei des Jobs das NFS im Feld volumes
ein.
Erstellen Sie eine package.json-Datei mit folgendem Inhalt:
{ "taskGroups": [ { "taskSpec": { "runnables": [ { "script": { "text": "echo Hello world from task ${BATCH_TASK_INDEX}. >> MOUNT_PATH/output_task_${BATCH_TASK_INDEX}.txt" } } ], "volumes": [ { "nfs": { "server": "NFS_IP_ADDRESS", "remotePath": "NFS_PATH" }, "mountPath": "MOUNT_PATH" } ] }, "taskCount": 3 } ], "logsPolicy": { "destination": "CLOUD_LOGGING" } }
Ersetzen Sie Folgendes:
NFS_IP_ADDRESS
: Die IP-Adresse des NFS. Wenn Ihr NFS beispielsweise eine Filestore-Dateifreigabe ist, geben Sie die IP-Adresse der Filestore-Instanz an, die Sie durch Beschreiben der Filestore-Instanz abrufen können.NFS_PATH
: Der Pfad des NFS-Verzeichnisses, auf das dieser Job zugreifen soll. Er muss mit einem/
gefolgt vom Stammverzeichnis des NFS beginnen. Für eine Filestore-Dateifreigabe mit dem NamenFILE_SHARE_NAME
stellt der Pfad/FILE_SHARE_NAME
beispielsweise das Stammverzeichnis der Dateifreigabe und der Pfad/FILE_SHARE_NAME/subdirectory
das Unterverzeichnissubdirectory
dar.MOUNT_PATH
: Der Bereitstellungspfad, über den die Runnables des Jobs auf dieses NFS zugreifen. Der Pfad muss mit/mnt/disks/
beginnen, gefolgt von einem Verzeichnis oder Pfad Ihrer Wahl. Wenn Sie dieses NFS-Volume beispielsweise mit einem Verzeichnis namensmy-nfs
darstellen möchten, legen Sie den Bereitstellungspfad auf/mnt/disks/my-nfs
fest.
Führen Sie dazu diesen Befehl aus:
gcloud batch jobs submit JOB_NAME \ --location LOCATION \ --config JSON_CONFIGURATION_FILE
Ersetzen Sie Folgendes:
JOB_NAME
: Der Name des Jobs.LOCATION
: Der Standort des Jobs.JSON_CONFIGURATION_FILE
: der Pfad zu einer JSON-Datei mit den Konfigurationsdetails des Jobs.
API
Wenn Sie mit der Batch API einen Job erstellen möchten, der ein NFS verwendet, verwenden Sie die jobs.create
-Methode und hängen Sie das NFS im Feld volumes
ein.
POST https://batch.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/jobs?job_id=JOB_NAME
{
"taskGroups": [
{
"taskSpec": {
"runnables": [
{
"script": {
"text": "echo Hello world from task ${BATCH_TASK_INDEX}. >> MOUNT_PATH/output_task_${BATCH_TASK_INDEX}.txt"
}
}
],
"volumes": [
{
"nfs": {
"server": "NFS_IP_ADDRESS",
"remotePath": "NFS_PATH"
},
"mountPath": "MOUNT_PATH"
}
]
},
"taskCount": 3
}
],
"logsPolicy": {
"destination": "CLOUD_LOGGING"
}
}
Ersetzen Sie Folgendes:
PROJECT_ID
: die Projekt-ID Ihres Projekts.LOCATION
: Der Standort des Jobs.JOB_NAME
: Der Name des Jobs.NFS_IP_ADDRESS
: die IP-Adresse des Network File System. Wenn Ihr NFS beispielsweise eine Filestore-Dateifreigabe ist, geben Sie die IP-Adresse der Filestore-Instanz an, die Sie durch Beschreiben der Filestore-Instanz abrufen können.NFS_PATH
: Der Pfad des NFS-Verzeichnisses, auf das dieser Job zugreifen soll. Er muss mit einem/
gefolgt vom Stammverzeichnis des NFS beginnen. Für eine Filestore-Dateifreigabe mit dem NamenFILE_SHARE_NAME
stellt der Pfad/FILE_SHARE_NAME
beispielsweise das Stammverzeichnis der Dateifreigabe und der Pfad/FILE_SHARE_NAME/subdirectory
ein Unterverzeichnis dar.MOUNT_PATH
: Der Bereitstellungspfad, über den die Runnables des Jobs auf dieses NFS zugreifen. Der Pfad muss mit/mnt/disks/
beginnen, gefolgt von einem Verzeichnis oder Pfad Ihrer Wahl. Wenn Sie dieses NFS-Volume beispielsweise mit einem Verzeichnis namensmy-nfs
darstellen möchten, legen Sie den Bereitstellungspfad auf/mnt/disks/my-nfs
fest.
Java
Node.js
Python
Nächste Schritte
- Wenn Probleme beim Erstellen oder Ausführen eines Jobs auftreten, finden Sie weitere Informationen unter Fehlerbehebung.
- Jobs und Aufgaben ansehen
- Weitere Optionen zum Erstellen von Jobs