如何使用node js将直播流发送到YouTube

npm init -y

npm install youtube-api video-stream ffmpeg fluent-ffmpeg

const Youtube = require('youtube-api');
const VideoStream = require('video-stream');
const ffmpeg = require('fluent-ffmpeg');

const YOUTUBE_API_KEY = 'YOUR_YOUTUBE_API_KEY';
const STREAM_URL = 'URL_OF_YOUR_LIVE_STREAM';

// 初始化 YouTube API
Youtube.authenticate({
  type: 'key',
  key: YOUTUBE_API_KEY
});

// 创建一个直播事件
Youtube.liveBroadcasts.insert({
  part: 'snippet,status',
  resource: {
    snippet: {
      title: 'Live Stream',
      description: 'This is a live stream'
    },
    status: {
      privacyStatus: 'public'
    }
  }
}, (err, broadcast) => {
  if (err) {
    console.error('Failed to create live broadcast:', err);
    return;
  }

  // 创建一个直播流
  const stream = Youtube.liveStreams.insert({
    part: 'snippet,status',
    resource: {
      snippet: {
        title: 'Live Stream'
      },
      cdn: {
        format: '720p',
        ingestionType: 'rtmp'
      }
    }
  }, (err, stream) => {
    if (err) {
      console.error('Failed to create live stream:', err);
      return;
    }

    // 开始直播
    Youtube.liveBroadcasts.bind({
      part: 'id,snippet',
      id: broadcast.id,
      streamId: stream.id
    }, (err, bindData) => {
      if (err) {
        console.error('Failed to bind broadcast and stream:', err);
        return;
      }

      console.log('Live streaming started.');

      // 获取直播流 URL
      Youtube.liveStreams.list({
        part: 'cdn',
        id: stream.id
      }, (err, streamList) => {
        if (err) {
          console.error('Failed to get stream URL:', err);
          return;
        }

        const rtmpUrl = streamList.items[0].cdn.ingestionInfo.ingestionAddress + '/' + streamList.items[0].cdn.ingestionInfo.streamName;
        console.log('RTMP URL:', rtmpUrl);

        // 发送直播流
        const inputStream = VideoStream(STREAM_URL);
        const outputStream = ffmpeg()
          .input(inputStream)
          .inputFormat('mpegts')
          .outputOptions('-c:v copy')
          .output(rtmpUrl)
          .on('start', () => console.log('Streaming started.'))
          .on('end', () => console.log('Streaming finished.'))
          .on('error', (err) => console.error('Streaming error:', err))
          .run();
      });
    });
  });
});

node streamToYouTube.js