comparison gcp_batch_netcat.py @ 2:79160beab2a4 draft

planemo upload for repository https://github.com/afgane/gcp_batch_netcat

1:cd36336ffaf6

import json
import subprocess
import argparse
import uuid

def main():
    parser = argparse.ArgumentParser()
    parser.add_argument('--nfs_address', required=True)
    parser.add_argument('--output', required=True)
    parser.add_argument('--project', required=True)
    parser.add_argument('--region', required=True)
    parser.add_argument('--port', default='2049')
    args = parser.parse_args()

    job_name = f'netcat-job-{uuid.uuid4()}'

    job_spec = {
        "taskGroups": [

        '--project', args.project,
        '--config', job_spec_file,
        '--format=text'
    ]

    try:
        result = subprocess.run(command, capture_output=True, text=True, check=True)
        with open(args.output, 'w') as f:
            f.write("Job output:\n")
            f.write(result.stdout)

2:79160beab2a4

import json
import subprocess
import argparse
import uuid
import time
import os

def main():
    parser = argparse.ArgumentParser()
    parser.add_argument('--nfs_address', required=True)
    parser.add_argument('--output', required=True)
    parser.add_argument('--project', required=True)
    parser.add_argument('--region', required=True)
    parser.add_argument('--port', default='2049')
    parser.add_argument('--service_account_key', required=True)
    args = parser.parse_args()

    # Set up authentication using the service account key
    os.environ['GOOGLE_APPLICATION_CREDENTIALS'] = args.service_account_key

    job_name = f'netcat-job-{uuid.uuid4()}'

    job_spec = {
        "taskGroups": [

        '--project', args.project,
        '--config', job_spec_file,
        '--format=text'
    ]

    # Wait 4 minutes before submitting the job
    time.sleep(240)

    try:
        result = subprocess.run(command, capture_output=True, text=True, check=True)
        with open(args.output, 'w') as f:
            f.write("Job output:\n")
            f.write(result.stdout)