Làm thế nào để tạo một trình theo dõi xu hướng Google trên Pipedream?

import { axios } from "@pipedream/platform"

export default defineComponent({
  async run({ steps, $ }) {
    const keywords = ["AI", "Machine Learning", "Data Science"];
    const allResults = {};
    
    for (const keyword of keywords) {
      console.log(`Đang xử lý từ khóa: ${keyword}`);
      
      const payload = {
        actor: "scraper.google.trends",
        input: {
          q: keyword,
          date: "today 1-m",
          data_type: "interest_over_time",
          hl: "en",
          tz: "420",
          geo: "",
          cat: "",
          property: "",
        },
        proxy: {
          country: "",
        }
      };

      try {
        const response = await axios($, {
          method: 'POST',
          url: 'https://api.scrapeless.com/api/v1/scraper/request',
          headers: {
            'Content-Type': 'application/json',
            'x-api-token': 'Scrapeless API KEY'
          },
          data: payload
        });
        
        console.log(`Phản hồi cho ${keyword}:`, response);
        
        if (response.job_id) {
          console.log(`Công việc được tạo cho ${keyword}, ID: ${response.job_id}`);
          
          let attempts = 0;
          const maxAttempts = 12;
          let jobResult = null;
          
          while (attempts < maxAttempts) {
            await new Promise(resolve => setTimeout(resolve, 10000));
            attempts++;
            
            try {
              const resultResponse = await axios($, {
                method: 'GET',
                url: `https://api.scrapeless.com/api/v1/scraper/result/${response.job_id}`,
                headers: {
                  'x-api-token': 'Scrapeless API KEY'
                }
              });
              
              console.log(`Cố gắng ${attempts} cho ${keyword}:`, resultResponse);
              
              if (resultResponse.status === 'completed') {
                jobResult = resultResponse.result;
```javascript
console.log(`Công việc đã hoàn thành cho ${keyword}:`, jobResult);
                break;
              } else if (resultResponse.status === 'failed') {
                console.error(`Công việc thất bại cho ${keyword}:`, resultResponse);
                break;
              } else {
                console.log(`Công việc vẫn đang chạy cho ${keyword}, trạng thái: ${resultResponse.status}`);
              }
            } catch (error) {
              console.error(`Lỗi khi kiểm tra trạng thái công việc cho ${keyword}:`, error);
            }
          }
          
          if (jobResult) {
            allResults[keyword] = jobResult;
          } else {
            allResults[keyword] = { 
              error: `Công việc đã hết thời gian hoặc thất bại sau ${attempts} lần thử`,
              job_id: response.job_id 
            };
          }
          
        } else {
          allResults[keyword] = response;
        }
        
      } catch (error) {
        console.error(`Lỗi cho ${keyword}:`, error);
        allResults[keyword] = { 
          error: `Yêu cầu thất bại: ${error.message}` 
        };
      }
    }
    
    console.log("Kết quả cuối:", JSON.stringify(allResults, null, 2));
    return allResults;
  },
})

{
  "từ khóa": {
    "trung bình": 0,
    "xu hướng": 0,
    "xu hướng hàng tuần": 0,
    "giá trị": [],
    "tối đa": 0,
    "tối thiểu": 0,
    "điểm dữ liệu": 0,
    "một phần": false,
    "lỗi": "Không tìm thấy dữ liệu dòng thời gian",
    "trạng thái": "lỗi",
    "các khóa có sẵn": data ? Object.keys(data) : []
  }
}

const tóm tắt = {
  thời gian: timestamp,
  tổng số từ khóa: Object.keys(processedData).length,
  số từ khóa thành công: Object.values(processedData).filter(d => d.status === 'success').length,
  thời gian: "hôm nay 1-m",
  dữ liệu: processedData
};

console.log("Dữ liệu đã xử lý cuối cùng:", JSON.stringify(summary, null, 2));
return summary;
},

---

Nó sẽ tính toán các chỉ số sau dựa trên dữ liệu được trả về từ Scrapeless:

* **Giá trị trung bình**
* **Thay đổi xu hướng hàng tuần** (7 ngày cuối so với 7 ngày trước)
* **Giá trị tối đa / tối thiểu**
* **Biến động**

**Lưu ý:**

* Mỗi từ khóa sẽ tạo ra một đối tượng phân tích chi tiết, giúp dễ dàng cho việc trực quan hóa và thông báo thêm.

### Bước 4 - thông báo discord (Đẩy báo cáo phân tích đến Discord)

1. Thêm bước Node.js cuối cùng, mã sau là ví dụ mã

const discordWebhookUrl = "https://discord.com/api/webhooks/1380448411299614821/MXzmQ14TOPK912lWhle_7qna2VQJBjWrdCkmHjdEloHKhYXw0fpBrp-0FS4MDpDB8tGh";

console.log("Xử lý dữ liệu cho Discord:", JSON.stringify(processedData, null, 2));

const currentDate = new Date().toLocaleString('en-US');

const từ khóa = Object.values(processedData.data);
const thành công = keywords.filter(k => k.status === 'success');

let người thực hiện tốt nhất = null;
let người thực hiện tệ nhất = null;
let xu hướng mạnh nhất = null;

if (thành công.length > 0) {
  người thực hiện tốt nhất = thành công.reduce((max, curr) => curr.average > max.average ? curr : max);
  người thực hiện tệ nhất = thành công.reduce((min, curr) => curr.average < min.average ? curr : min);
  xu hướng mạnh nhất = thành công.reduce((max, curr) => Math.abs(curr.weeklyTrend) > Math.abs(max.weeklyTrend) ? curr : max);
}

const thông điệp discord = {
  nội dung: `📊 **Báo cáo Xu hướng Google** - ${currentDate}`,
  nhúng: [
    {
      tiêu đề: "🔍 Phân tích Xu hướng",
      màu: 3447003,
      thời gian: new Date().toISOString(),
      trường: [
        {
          tên: "📈 Tóm tắt",
          giá trị: `**Thời gian:** Tháng trước\n**Từ khóa phân tích:** ${processedData.totalKeywords}\n**Thành công:** ${processedData.successfulKeywords}/${processedData.totalKeywords}`,
          inline: false
        }
      ]
    }
  ]
};

if (thành công.length > 0) {
  const chi tiết từ khóa = thành công.map(data => {
    const biểu tượng xu hướng = data.weeklyTrend > 5 ? '🚀' : 
                               data.weeklyTrend > 0 ? '📈' : 
                               data.weeklyTrend < -5 ? '📉' : 
                               data.weeklyTrend < 0 ? '⬇️' : '➡️';
    
    const biểu tượng hiệu suất = data.average > 70 ? '🔥' : 
                                 data.average > 40 ? '✅' : 
                                 data.average > 20 ? '🟡' : '🔴';
    
    return {
      tên: `${biểu tượng hiệu suất} ${data.keyword}`,
      giá trị: `**Điểm:** ${data.average}/100\n**Xu hướng:** ${biểu tượng xu hướng} ${data.weeklyTrend > 0 ? '+' : ''}${data.weeklyTrend}\n**Phạm vi:** ${data.min}-${data.max}`,
      inline: true
    };
  });
  
  thông điệp discord.embeds[0].fields.push(...chi tiết từ khóa);
}

if (người thực hiện tốt nhất && thành công.length > 1) {
  thông điệp discord.embeds.push({
    tiêu đề: "🏆 Điểm Nổi Bật",
    màu: 15844367,
    trường: [
      {
        tên: "🥇 Người Thực Hiện Tốt Nhất",
        giá trị: `**${người thực hiện tốt nhất.keyword}** (${người thực hiện tốt nhất.average}/100)`,
        inline: true
      },
      {
        tên: "📊 Điểm Thấp Nhất",
        giá trị: `**${người thực hiện tệ nhất.keyword}** (${người thực hiện tệ nhất.average}/100)`,
        inline: true
      },
      {
        tên: "⚡ Xu hướng Mạnh Nhất",
        giá trị: `**${xu hướng mạnh nhất.keyword}** (${xu hướng mạnh nhất.weeklyTrend > 0 ? '+' : ''}${xu hướng mạnh nhất.weeklyTrend})`,
        inline: true
      }
    ]
  });
}

const thất bại = từ khóa.filter(k => k.status === 'error');
if (thất bại.length > 0) {
  thông điệp discord.embeds.push({
    tiêu đề: "❌ Lỗi",
    màu: 15158332,
    trường: thất bại.map(data => ({
      tên: data.keyword,
      giá trị: data.error || "Lỗi không xác định",
      inline: true
    }))
  });
}

```vi
}

console.log("Tin nhắn Discord để gửi:", JSON.stringify(discordMessage, null, 2));

try {
  const response = await axios($, {
    method: 'POST',
    url: discordWebhookUrl,
    headers: {
      'Content-Type': 'application/json'
    },
    data: discordMessage
  });
  
  console.log("Phản hồi webhook Discord:", response);
  
  return {
    webhook_sent: true,
    platform: "discord",
    message_sent: true,
    keywords_analyzed: processedData.totalKeywords,
    successful_keywords: processedData.successfulKeywords,
    timestamp: currentDate,
    discord_response: response
  };
  
} catch (error) {
  console.error("Lỗi webhook Discord:", error);
  
  const simpleMessage = {
    content: `📊 **Báo cáo Google Trends - ${currentDate}**\n\n` +
            `📈 **Kết quả (${processedData.successfulKeywords}/${processedData.totalKeywords}):**\n` +
            successful.map(data => 
              `• **${data.keyword}**: ${data.average}/100 (${data.weeklyTrend > 0 ? '+' : ''}${data.weeklyTrend})`
            ).join('\n') +
            (failed.length > 0 ? `\n\n❌ **Lỗi:** ${failed.map(d => d.keyword).join(', ')}` : '')
  };
  
  try {
    const fallbackResponse = await axios($, {
      method: 'POST',
      url: discordWebhookUrl,
      headers: {
        'Content-Type': 'application/json'
      },
      data: simpleMessage
    });
    
    return {
      webhook_sent: true,
      platform: "discord",
      message_sent: true,
      fallback_used: true,
      discord_response: fallbackResponse
    };
    
  } catch (fallbackError) {
    console.error("Lỗi dự phòng Discord:", fallbackError);
    
    return {
      webhook_sent: false,
      platform: "discord",
      error: error.message,
      fallback_error: fallbackError.message,
      data_summary: {
        keywords: processedData.totalKeywords,
        successful: processedData.successfulKeywords,
        best_performer: bestPerformer?.keyword,
        best_score: bestPerformer?.average
      }
    };
  }
}
},