Product Finder（製品ファインダー）を使う #Keepa #API #JavaScript

const rp = require('request-promise');

const key = 'APIキーを入力してください';

const queryJSON = {
    "perPage": 100, // 1ページあたりの結果数
    "page": 0, // ページ番号
    "productType": 0, // 製品タイプ
    "rootCategory": "2127209051", // ルートカテゴリID
    "title": "ノートパソコン -Apple", // タイトルキーワード
    "avg90_NEW_gte": 30000, // 直近90日の新品価格の平均が30,000円以上
    "current_SALES_gte": 1000, // 現在のランキングが1,000位以上
    "current_SALES_lte": 20000, // 現在のランキングが20,000位以下
    "current_LISTPRICE_gte": 30000, // リスト価格が30,000円以上
    "isPrimeExclusive": false // Prime限定ではない商品も含む
};

const options = {
    url: 'https://api.keepa.com/query?domain=5&key=' + key,
    method: 'POST',
    headers: {
        'Content-Type': 'application/json',
        'Connection': 'keep-alive'
    },
    body: {
        'selection': JSON.stringify(queryJSON)
    },
    json: true
};

rp(options)
    .then(response => {
        const asinList = response.asinList; // 条件に合ったASINの配列
        console.log('この条件にマッチするASINの合計数: ' + response.totalResults);
        console.log('ASINリスト: ', asinList);
    })
    .catch(err => {
        console.error('エラーが発生しました: ', err);
    });

pip install keepa

import keepa
import asyncio

async def product_finder_example():
    # Keepa APIキーを設定
    api_key = 'あなたのAPIキーをここに入力'

    # Keepa APIクライアントを初期化
    api = await keepa.AsyncKeepa.create(api_key)

    # 検索条件を設定
    product_params = {
        "perPage": 100,
        "page": 0,
        "productType": 0,
        "rootCategory": "2127209051",  # ノートパソコンカテゴリ
        "title": "ノートパソコン -Apple",
        "avg90_NEW_gte": 30000,  # 直近90日の新品価格の平均が30,000円以上
        "current_SALES_gte": 1000,  # 現在のランキングが1,000位以上
        "current_SALES_lte": 20000,  # 現在のランキングが20,000位以下
        "current_LISTPRICE_gte": 30000,  # リスト価格が30,000円以上
        "isPrimeExclusive": False  # Prime限定ではない商品も含む
    }

    try:
        # Product Finder APIを呼び出し
        results = await api.product_finder(product_params)

        # 結果を表示
        print(f"検索結果の総数: {results['totalResults']}")
        print("ASINリスト:")
        for asin in results['asinList']:
            print(asin)

    except Exception as e:
        print(f"エラーが発生しました: {e}")

    finally:
        # APIクライアントを閉じる
        await api.close()

# 非同期関数を実行
asyncio.run(product_finder_example())