翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Neptune での Gremlin トランザクション

Gremlin トランザクションが実行されるコンテキストはいくつかあります。Gremlin を使用する際には、作業対象となるコンテキストとその意味を理解することが重要です。

上記のコンテキストのどちらでも、リクエストがセッションレスまたはセッションにバインドされた状態で送信されるという追加のコンテキストがあります。

セッションレスリクエスト

セッションレスの場合、リクエストは 1 回のトランザクションに相当します。

スクリプトの場合、1 回のリクエストで送信された 1 つ以上の Gremlin ステートメントが 1 つのトランザクションとしてコミットまたはロールバックされることを意味します。例えば、次のようになります。

Cluster cluster = Cluster.open();
Client client = cluster.connect(); // sessionless
// 3 vertex additions in one request/transaction:
client.submit("g.addV();g.addV();g.addV()").all().get();

バイトコードの場合、g からトラバーサルが生成され実行されるたびに、セッションレスリクエストが行われます。

GraphTraversalSource g = traversal().withRemote(...);

// 3 vertex additions in three individual requests/transactions:
g.addV().iterate();
g.addV().iterate();
g.addV().iterate();

// 3 vertex additions in one single request/transaction:
g.addV().addV().addV().iterate();

セッションにバインドされたリクエスト

セッションにバインドすると、1 つのトランザクションのコンテキスト内で複数のリクエストを適用できます。

スクリプトの場合、すべてのグラフ操作を連結して 1 つの埋め込み文字列値にする必要がないということです。

Cluster cluster = Cluster.open();
Client client = cluster.connect(sessionName); // session
try {
    // 3 vertex additions in one request/transaction:
    client.submit("g.addV();g.addV();g.addV()").all().get();
} finally {
    client.close();
}

try {
    // 3 vertex additions in three requests, but one transaction:
    client.submit("g.addV()").all().get(); // starts a new transaction with the same sessionName
    client.submit("g.addV()").all().get();
    client.submit("g.addV()").all().get();
} finally {
    client.close();
}

スクリプトベースのセッションの場合、 でクライアントを閉じるとトランザクションがclient.close()コミットされます。スクリプトベースのセッションで使用できる明示的なロールバックコマンドはありません。ロールバックを強制するには、クライアントを閉じるg.inject(0).fail('rollback')前に などのクエリを発行することで、トランザクションを失敗させることができます。

バイトコードの場合、トランザクションを明示的に制御し、セッションを透過的に管理できます。Gremlin 言語バリアント (GLV) は、以下のように Gremlin の tx() 構文をサポートして、トランザクションを commit() または rollback() します。

GraphTraversalSource g = traversal().withRemote(conn);

Transaction tx = g.tx();

// Spawn a GraphTraversalSource from the Transaction.
// Traversals spawned from gtx are executed within a single transaction.
GraphTraversalSource gtx = tx.begin();
try {
    gtx.addV('person').iterate();
    gtx.addV('software').iterate();

    tx.commit();
} finally {
    if (tx.isOpen()) {
        tx.rollback();
    }
}

上記の例は Java で書かれていますが、このtx()構文を他の言語でも使用できます。言語固有のトランザクション構文については、Java、Python、Javascript、.NET、Go に関する Apache TinkerPop ドキュメントの「トランザクション」セクションを参照してください。

バイトコードコミットとロールバックのタイムアウト動作

tx() 構文でバイトコードベースのトランザクションを使用する場合、 commit() および rollback()オペレーションはクエリタイムアウト設定の対象になりません。で設定されたグローバルneptune_query_timeoutパラメータもクエリごとのタイムアウト値も、これらのオペレーションevaluationTimeoutには適用されません。サーバーで、完了するかエラーが発生するまで、時間制限なしで commit()と rollback()を実行します。

クライアント側では、サーバーが応答するまで Gremlin ドライバーの tx.commit()および tx.rollback()呼び出しは完了しません。言語によっては、これはブロック呼び出しまたは未解決の非同期オペレーションとして現れる場合があります。これらの呼び出しをバインドする組み込みタイムアウト設定を提供するドライバーはありません。これらのトランザクション機能に関する同時実行動作の詳細については、特定の Gremlin 言語バリアントの API ドキュメントを参照してください。

アプリケーションが commit()または を待機する時間を制限する必要がある場合はrollback()、言語の同時実行機能を使用してクライアント側のタイムアウトを適用できます。クライアント側のタイムアウトが発生した場合、サーバーはオペレーションの処理を続行します。サーバー側のオペレーションは、完了するまでワーカースレッドを保持します。クライアント側のタイムアウト後、トランザクションの状態が不確定であるため、既存の接続を再利用するのではなく、接続を閉じて新しい接続を作成します。

サーバー側のトランザクションクリーンアップ

クライアントがコミットまたはロールバックせずにトランザクションを切断または中止した場合、Neptune にはサーバー側のメカニズムがあり、最終的に孤立したトランザクションをクリーンアップします。

これらのクリーンアップメカニズムはセーフティネットです。トランザクションが終了したら、常に明示的にコミットまたはロールバックすることをお勧めします。