Node :等待python脚本写入文件，然后上传到s3

const { exec } = require('child_process');
const fs = require('fs');
const AWS = require('aws-sdk');

// 执行 Python 脚本
exec('python write_file.py', (error, stdout, stderr) => {
  if (error) {
    console.error(`执行出错: ${error}`);
    return;
  }
  console.log(`stdout: ${stdout}`);
  console.error(`stderr: ${stderr}`);

  // 等待文件写入完成
  fs.readFile('output.txt', (err, data) => {
    if (err) throw err;

    // 配置 AWS SDK
    const s3 = new AWS.S3({
      accessKeyId: 'YOUR_ACCESS_KEY_ID',
      secretAccessKey: 'YOUR_SECRET_ACCESS_KEY',
      region: 'YOUR_REGION'
    });

    // 上传文件到 S3
    const params = {
      Bucket: 'YOUR_BUCKET_NAME',
      Key: 'uploaded_file.txt',
      Body: data
    };

    s3.upload(params, (err, data) => {
      if (err) {
        console.error(err);
        return;
      }
      console.log(`文件上传成功: ${data.Location}`);
    });
  });
});

const { exec } = require('child_process');
const fs = require('fs').promises;
const AWS = require('aws-sdk');

async function executePythonScript() {
  return new Promise((resolve, reject) => {
    exec('python write_file.py', (error, stdout, stderr) => {
      if (error) {
        reject(error);
      } else {
        resolve(stdout);
      }
    });
  });
}

async function uploadToS3() {
  try {
    await executePythonScript();

    const data = await fs.readFile('output.txt');

    const s3 = new AWS.S3({
      accessKeyId: 'YOUR_ACCESS_KEY_ID',
      secretAccess书Key: 'YOUR_SECRET_ACCESS_KEY',
      region: 'YOUR_REGION'
    });

    const params = {
      Bucket: 'YOUR_BUCKET_NAME',
      Key: 'uploaded_file.txt',
      Body: data
    };

    const result = await s3.upload(params).promise();
    console.log(`文件上传成功: ${result.Location}`);
  } catch (error) {
    console.error(error);
  }
}

uploadToS3();