如何借助shopify-api-node获取带关联集合的Shopify产品Feed？

一、先解决获取所有Collections的问题 #

你可以通过shopify-api-node的collections.list方法批量获取所有集合，注意处理Shopify API的分页限制（默认单页最多返回250条数据）：

const Shopify = require('shopify-api-node');

const shopify = new Shopify({
  shopName: '你的店铺域名.myshopify.com',
  apiKey: '你的API密钥',
  password: '你的API密码',
});

async function getAllCollections() {
  let allCollections = [];
  let pageInfo = null;

  do {
    const requestOptions = pageInfo ? { limit: 250, page_info: pageInfo } : { limit: 250 };
    const response = await shopify.collection.list(requestOptions);
    allCollections = [...allCollections, ...response];
    
    // 提取下一页的分页标识
    const linkHeader = await shopify.request.response.headers.get('link');
    if (linkHeader) {
      const nextPageMatch = linkHeader.match(/<([^>]+)>; rel="next"/);
      pageInfo = nextPageMatch ? new URL(nextPageMatch[1]).searchParams.get('page_info') : null;
    } else {
      pageInfo = null;
    }
  } while (pageInfo);

  return allCollections;
}

二、批量获取所有Collects（产品-集合关联关系） #

你已经能下载Collects，同样需要处理分页逻辑：

async function getAllCollects() {
  let allCollects = [];
  let pageInfo = null;

  do {
    const requestOptions = pageInfo ? { limit: 250, page_info: pageInfo } : { limit: 250 };
    const response = await shopify.collect.list(requestOptions);
    allCollects = [...allCollects, ...response];
    
    const linkHeader = await shopify.request.response.headers.get('link');
    pageInfo = linkHeader ? linkHeader.match(/<([^>]+)>; rel="next"/)?.[1]?.split('page_info=')[1] : null;
  } while (pageInfo);

  return allCollects;
}

三、关联产品、Collects与Collections，得到每个产品的关联集合 #

1. 先获取你已有的全量产品列表（注意同样要处理分页）
2. 结合上面获取的集合和关联关系数据，构建映射后关联到产品上：

async function getProductsWithCollections(allProducts) {
  const allCollections = await getAllCollections();
  const allCollects = await getAllCollects();

  // 构建集合ID到集合详情的映射，方便快速查询
  const collectionMap = allCollections.reduce((map, collection) => {
    map[collection.id] = collection;
    return map;
  }, {});

  // 构建产品ID到关联集合ID列表的映射
  const productToCollectionIds = allCollects.reduce((map, collect) => {
    if (!map[collect.product_id]) {
      map[collect.product_id] = [];
    }
    map[collect.product_id].push(collect.collection_id);
    return map;
  }, {});

  // 给每个产品追加关联集合信息
  return allProducts.map(product => ({
    ...product,
    associated_collections: productToCollectionIds[product.id]?.map(id => collectionMap[id]) || []
  }));
}

// 调用示例（需先获取全量产品）
// const allProducts = await shopify.product.list({ limit: 250 }); // 记得处理分页
// const productsWithCollections = await getProductsWithCollections(allProducts);

关键提示 #

• 这种方式仅需3次批量请求（产品、Collections、Collects），避免了1000次单个产品的API调用，效率大幅提升
• 必须处理分页逻辑，否则会遗漏超过单页限制的数据
• 如果店铺数据量极大，可在请求之间添加短暂延迟，避免触发Shopify API的速率限制

内容的提问来源于stack exchange，提问作者Rezaul karim