Node.js SDK並發匯出資料 -

當使用情境中不關心整個結果集的順序時，您可以使用並發匯出資料功能以更快的速度將命中的資料全部返回。

前提條件

已初始化Client。具體操作，請參見初始化Client。
已建立資料表並寫入資料。具體操作，請參見建立資料表和寫入資料。
已在資料表上建立多元索引。具體操作，請參見建立多元索引。

參數

參數		說明
tableName		資料表名稱。
indexName		多元索引名稱。
scanQuery	query	多元索引的查詢語句。支援精確查詢、模糊查詢、範圍查詢、地理位置查詢、巢狀查詢等，功能和Search介面一致。
	limit	掃描資料時一次能返回的資料行數。
	maxParallel	最大並發數。請求支援的最大並發數由使用者資料量決定。資料量越大，支援的並發數越多，每次任務前可以通過ComputeSplits API進行擷取。
	currentParallelId	當前並發ID。取值範圍為[0, maxParallel)。
	token	用於翻頁功能。ParallelScan請求結果中有下一次進行翻頁的token，使用該token可以接著上一次的結果繼續讀取資料。
	aliveTime	ParallelScan的當前任務有效時間，也是token的有效時間。預設值為60，建議使用預設值，單位為秒。如果在有效時間內沒有發起下一次請求，則不能繼續讀取資料。持續發起請求會重新整理token有效時間。說明動態修改schema中的切換索引、服務端單台機器故障、服務端負載平衡等均會導致Session提前到期，此時需要重新建立Session。
columnsToGet		指定分組結果中需要返回的列名，可以通過將列名加入Columns來實現。如果需要返回多元索引中的所有列，則可以使用更簡潔的ReturnAllFromIndex實現。重要此處不能使用ReturnAll。
sessionId		本次並發掃描資料任務的sessionId。建立Session可以通過ComputeSplits API來建立，同時獲得本次任務支援的最大並發數。

樣本

以下樣本用於並發匯出資料。

//1.擷取sessionId。
let computeSplits = await new Promise((resolve, reject) => {
    client.computeSplits({
        tableName: tableName,
        searchIndexSplitsOptions: {
            indexName: indexName,
        }
    }, function (err, data) {
        if (err) {
            console.log('computeSplits error:', err.toString());
            reject(err);
        } else {
            console.log('computeSplits success:', data);
            resolve(data)
        }
    })
})

//2.構造query。
const scanQuery = {
    query: {
        queryType: TableStore.QueryType.MATCH_ALL_QUERY,
    },
    limit: 1000,
    aliveTime: 30,
    token: undefined,
    currentParallelId: 0,
    maxParallel: 1,
}

//3.構造ParallelScan請求（該樣本為了方便介紹使用同步請求進行展示，實際業務中可修改為非同步）。
const parallelScanPromise = function () {
    return new Promise(function (resolve, reject) {
        client.parallelScan({
            tableName: tableName,
            indexName: indexName,
            columnToGet: {
                returnType: TableStore.ColumnReturnType.RETURN_ALL_FROM_INDEX,
            },
            sessionId: computeSplits.sessionId,
            scanQuery: scanQuery,
        }, function (err, data) {
            if (err) {
                console.log('parallelScan error:', err.toString());
                reject(err);
            } else {
                console.log("parallelScan, rows:", data.rows.length)
                resolve(data)
            }
        });
    })
}
let totalCount = 0 //範例程式碼記錄總行數。
let parallelScanResponse = await parallelScanPromise()
totalCount = totalCount + parallelScanResponse.rows.length
//4.迭代拉取資料，直到拉取所有資料結束。
while (parallelScanResponse.nextToken !== null && parallelScanResponse.nextToken.length > 0) {
    scanQuery.token = parallelScanResponse.nextToken
    parallelScanResponse = await parallelScanPromise()
    totalCount += parallelScanResponse.rows.length
}
console.log("total rows:", totalCount)

常見問題

使用多元索引Search介面查不到資料

：並發匯出資料

前提條件

參數

樣本

常見問題

相關文檔