JP7735645B2 - データ処理方法、装置、電子機器、及びコンピュータプログラム - Google Patents

Description

（関連出願への相互参照）
本願は、２０２２年１２月２２日に中国特許局に提出された、出願番号が２０２２１１６５８５５６．０である中国特許出願の優先権を主張し、その内容の全てが引用により本願に組み込まれる。

本願は、ブロックチェーン技術分野に関し、特に、データ処理方法、装置、電子機器、及びコンピュータプログラムに関するものである。

関連技術では、データ処理を行う際に、通常、サーバ側に集中配置されたデータ処理エンジンにより、対象によってトリガされたデータ処理要求に応じて、対応的にデータ処理を行い、ここで、データ処理エンジンが提供するデータ処理機能は、複数のサブシステム機能で構成され、複数のサブシステム機能は、負荷分散サブシステム、各種処理機能サブシステム、及びネットワーク分散サブシステムなどを含む。

しかしながら、データ処理エンジンが集中配置されているため、障害発生時やサービスアップグレード時に、ユーザへのデータ処理サービスの提供、ユーザのデータ処理ニーズの保障ができず、しかも集中配置時の地理的制限によりサービス拡張を実現することが困難である。また、現在のデータ処理エンジンは、データ処理を完了した後、一定期間内の処理結果しか記憶できないため、広範囲の過去データに対する処理ニーズを満たすことができず、さらに、複数のサブシステムの機能の総合的な処理効果の保証は、実現が難しく、保守コストも高くなる。

本願の実施例は、ブロックチェーンシステム内のノード機器及びブロックチェーンに記憶されたスマートコントラクトにより、様々なデータ処理機能を実現でき、関連対象のデータ処理ニーズを保証しつつ、保守及び配置の複雑度を大幅に低減できるデータ処理方法、装置、電子機器、コンピュータ記憶媒体及びコンピュータプログラム製品を提供する。

本願の実施例は、ブロックチェーンシステム内のノード機器に適用されるデータ処理方法を提供し、前記方法は、
対象機器から送信されたデータ処理要求を受信し、前記データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、前記処理待ちデータに対する操作タイプ情報、及び前記対象機器の対象識別情報を取得するステップであって、１つのコントラクト識別情報は、１つのスマートコントラクトを識別するために使用され、前記１つのスマートコントラクトには、少なくとも１つのデータ処理機能の処理ロジックが保存されている、ステップと、
前記コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、前記目標スマートコントラクトにおける前記操作タイプ情報に対応する処理方式に従って、前記処理待ちデータを処理して、データ処理結果を得るステップと、
前記データ処理結果を前記対象機器にフィードバックするステップと、を含む。

本願の実施例は、データ処理装置を提供し、前記装置は、受信ユニットと、処理ユニットと、フィードバックユニットと、を備え、
前記受信ユニットは、対象機器から送信されたデータ処理要求を受信し、前記データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、前記処理待ちデータに対する操作タイプ情報、及び前記対象機器の対象識別情報を取得するように構成され、１つのコントラクト識別情報は、１つのスマートコントラクトを識別するために使用され、前記１つのスマートコントラクトには、少なくとも１つのデータ処理機能の処理ロジックが保存されており、
前記処理ユニットは、前記コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、前記目標スマートコントラクトにおける前記操作タイプ情報に対応する処理方式に従って、前記処理待ちデータを処理して、データ処理結果を得るように構成され、
前記フィードバックユニットは、前記データ処理結果を前記対象機器にフィードバックするように構成される。

本願の実施例は、電子機器を提供し、前記電子機器は、メモリと、プロセッサと、メモリに記憶され、プロセッサで実行可能なコンピュータプログラムと、を備え、前記プロセッサは、前記プログラムを実行するときに、上記のいずれかに記載のデータ処理方法を実現する。

本願の実施例は、コンピュータプログラムが記憶されたコンピュータ可読記憶媒体を提供し、前記コンピュータプログラムは、プロセッサによって実行されるときに、上記のいずれかに記載のデータ処理方法を実現する。

本願の実施例は、コンピュータプログラムを含むコンピュータプログラム製品を提供し、前記コンピュータプログラムは、プロセッサによって実行されるときに、上記のいずれかに記載のデータ処理方法を実現する。

本願は、以下の有益な効果を有する。

本願の実施例では、データ処理方法、装置、電子機器、コンピュータ記憶媒体及びコンピュータプログラム製品を提案し、対象機器のデータ処理要求に基づいてデータ処理機能を実現する際に、ブロックチェーンシステム内のノード機器及びブロックチェーンに記憶されたスマートコントラクトにより、様々なデータ処理機能を実現することができ、データ処理を遂行するためのシステム構成を簡素化し、データ処理エンジンに対する保守及び配置を、ブロックチェーンにおけるスマートコントラクトの配置及び更新に変換することで、保守及び配置の複雑度を大幅に低減することができる。また、ブロックチェーンシステムの分散アーキテクチャにより、データ処理機能の分散構築を実現することができ、データ処理の実行時に、データ処理要求に指示される目標スマートコントラクトを呼び出すことで、処理待ちデータに対して対応的にデータ処理を行うことができる。したがって、ブロックチェーンにより、ノード機器に各種データ処理機能を容易に配置することができ、これにより、データ処理機能の実現時の配置コスト及び保守コストを大幅に削減し、データ処理サービスを容易に拡張することができ、サービス拡張が地域要因によって制限される問題を解決する。さらに、ブロックチェーンシステム内の各ノード機器にブロックチェーンが記憶されている特性により、ブロックチェーンシステム内の１つのノード機器が故障した場合に、他のノード機器も同じ処理機能を実現できるため、１つのノード機器の故障によってデータ処理サービスの正常な動作に影響を与えることなく、それにより、対象機器が無感知の状態で、データ処理要求に対する正常な応答を保証することができる。

本願の実施例における従来技術のデータ処理エンジンのアーキテクチャの概略図である。 本願の実施例における適用可能なシーンの概略図である。 本願の実施例におけるデータ処理のフローチャートである。 本願の実施例において、記憶されている各スマートコントラクトのアーキテクチャの概略図である。 本願の実施例におけるスマートコントラクトでサポートされる機能の概略図である。 本願の実施例におけるデータ処理取引の実行順序の比較図である。 本願の実施例におけるトラステッドコンピューティング処理の実現プロセスの概略図である。 本願の実施例におけるトラステッドコンピューティング処理の別の実現プロセスの概略図である。 本願の実施例におけるスマートコントラクトを呼び出して取引を実行するフローチャートである。 本願の実施例におけるデータ処理装置の論理構造を示す模式図である。 本願の実施例における電子機器のハードウェア構成を示す模式図である。 本願の実施例におけるコンピューティング装置の構成を示す模式図である。

本願の実施例の目的、技術的解決策及び利点をより明確にするために、以下では、本願の実施例の図面を参照して、本願の実施例の技術的解決策を明確且つ完全に説明する。明らかに、説明される実施例は、本願の技術的解決策の実施例の一部であり、全部の実施例ではない。本願の明細書に記載された実施例に基づいて、創造的な労力を払わずに当業者によって得られる他のすべての実施例は、本願の保護範囲に含まれる。

本願の明細書、特許請求の範囲及び上記の図面における「第１」、「第２」などの用語は、特定の順番又は前後順番を限定するものではなく、類似する対象を区別するものである。理解すべきこととして、このように使用されるデータは、適切な場合に交換できるため、本明細書で説明される本発明の実施例は、本明細書で図示又は説明されるもの以外の順序で実施できる。

当業者の理解を容易にするために、本願の実施例における用語の一部を以下に説明する。

ブロックチェーン：情報技術分野の分散帳簿技術を指し、一般的にコンセンサス、取引ブロック、及び状態データ記憶、暗号的なＩＤセキュリティなどで構成される。また、帳簿は分散して記憶され、且つブロックはコンセンサスされているため、改ざん防止、追跡可能、共通保守という特徴を有する。

コンセンサス：ブロックチェーンシステム内のすべてのノードが共同でブロック発展を維持するメカニズムを指し、一般的なコンセンサスメカニズムには、プルーフ・オブ・ワーク（ＰＯＷ：Ｐｒｏｏｆ ｏｆ Ｗｏｒｋ）、プルーフ・オブ・ステーク（ＰＯＳ：ｐｒｏｏｆ ｏｆ ｓｔａｋｅ）、デリゲート・プルーフ・オブ・ステーク（ＤＰＯＳ：Ｄｅｌｅｇａｔｅｄ Ｐｒｏｏｆ ｏｆ Ｓｔａｋｅ）、ビザンチン・フォールト・トレランス（ＰＢＦＴ：Ｐｒａｃｔｉｃａｌ Ｂｙｚａｎｔｉｎｅ Ｆａｕｌｔ Ｔｏｌｅｒａｎｃｅ）などを含む。

ノード：又はノード機器とは、ブロックチェーンシステムにおいてブロックチェーンの保守に参加する最小ユニットであり、ブロックチェーンノードプログラムの配置と実行ユニットである。

データ処理エンジン：データ処理機能を提供するために使用されるツールであり、一般的に、外部標準のｒｅｓｔｆｕｌインターフェース、又はリモートプロシージャコールインターフェース（ＧＲＰＣ：Ｇｏｏｇｌｅ Ｒｅｍｏｔｅ Ｐｒｏｃｅｄｕｒｅ Ｃａｌｌ）、又はｗｅｂｓｏｃｋｅｔインターフェースサービス、又は関数レベルのアプリケーション・プログラミング・インターフェース（ＡＰＩ：Ａｐｐｌｉｃａｔｉｏｎ Ｐｒｏｇｒａｍｍｉｎｇ Ｉｎｔｅｒｆａｃｅ）呼び出し機能を提供するツールである。

ブロックチェーンは、分散データ記憶、ポイントツーポイント伝送、コンセンサスメカニズム、暗号化アルゴリズムなどのコンピュータ技術の新しい応用形態である。ブロックチェーン（Ｂｌｏｃｋｃｈａｉｎ）は、本質的に脱中心化のデータベースであり、暗号的相関方法を使用して関連付けられて生成された一連のデータブロックであり、各データブロックには、その情報の有効性（偽造防止）を検証し、次のブロックを生成するための同一バッチのネットワーク取引情報が含まれている。ブロックチェーンは、ブロックチェーン基礎プラットフォーム、プラットフォーム製品サービス層、アプリケーションサービス層を含み得る。

ブロックチェーン基礎プラットフォームは、ユーザ管理、基本サービス、スマートコントラクト、及び運用モニタリングなどの処理モジュールを含み得る。ここで、ユーザ管理モジュールは、公開鍵と秘密鍵の生成の維持（アカウント管理）、鍵の管理、ユーザの実身元とブロックチェーンアドレスの対応関係の維持（権限管理）などを含む、すべてのブロックチェーン参加者の身元情報管理の役割を果たし、承認した上で特定の実身元に関する取引状況を監督・監査し、リスクコントロールのための規則の設定（リスクコントロール監査）を提供する。基本サービスモジュールは、すべてのブロックチェーンノード機器に配置され、サービス要求の有効性を検証し、有効な要求に対するコンセンサスを完了した後に記憶に記録するために使用され、新しいサービス要求に対して、基本サービスは、まず、インターフェースの適応解析と認証処理（インターフェイスの適応）を行い、次に、コンセンサスアルゴリズムを介してサービス情報を暗号化（コンセンサス管理）し、暗号化後に整合性を取って共有帳簿（ネットワーク通信）に伝送し、記録記憶を行う。スマートコントラクトモジュールは、コントラクト登録と発行、コントラクトトリガとコントラクト実行の役割を果たす。開発者は、特定のプログラミング言語でコントラクトロジックを定義し、ブロックチェーンに配置（コントラクト登録）し、コントラクト条件のロジックに従って、鍵又はその他のイベントを呼び出して実行をトリガしてコントラクトロジックを完了させ、同時に、コントラクトのアップグレードキャンセルの機能を提供する。運用モニタリングモジュールは、主に製品リリースプロセスの配置、構成変更、コントラクト設定、クラウド適応、及び製品運用のリアルタイムステータスの可視化出力、例えば、警告、ネットワーク状況のモニタリング、ノード機器のヘルス状態のモニタリングなどの役割を果たす。

プラットフォーム製品サービス層は、典型的なアプリケーションの基本的な機能と実現フレームワークを提供し、開発者はこれらの基本的な機能に基づいてサービスの特性を重ね合わせ、サービスロジックのブロックチェーン実現を完成させることができる。アプリケーションサービス層は、ブロックチェーン方案に基づくアプリケーションサービスを、サービス参加者が使用できるように提供する。

以下では、本願の実施例の設計思想について簡単に説明する。

データ処理を行う際に、現在のデータ処理技術のほとんどは、クラウドサービスに基づく集中型サービスシステムであり、いくつかの実施例では、データ処理は集中配置されたデータ処理エンジンによって実現される。データ処理サービスを提供するプロセスでは、通常、標準的なｒｅｓｔｆｕｌインターフェースを提供することによってサービスが提供され、関連対象は、ｒｅｓｔｆｕｌインターフェースを介してデータ処理タスクの遂行することを要求し、さらに、サーバ側のデータ処理エンジンによって対応的にデータ処理を行い、サーバ側のデータ処理システム（又はデータ処理エンジン）は、通常、多層アーキテクチャを有する。

図１に示すように、図１は、本願の実施例における従来技術のデータ処理エンジンのアーキテクチャの概略図である。図１から分かるように、従来技術では、データ処理を実現するためのデータ処理エンジン１００には、コンテンツ配信ネットワーク（ＣＤＮ：Ｃｏｎｔｅｎｔ Ｄｅｌｉｖｅｒｙ Ｎｅｔｗｏｒｋ）サブシステム２００、負荷分散サブシステム３００、データサブ処理システム４００－１～データサブ処理システム４００－ｎ、データ統計サブシステム５００、システムモニタリングサブシステム６００、及びデータ記憶サブシステム７００などの多層アーキテクチャを含む。

ＣＤＮサブシステム２００は、ネットワーク帯域幅が小さく、アクセス量などの問題を解決するために使用され、対象機器の応答速度を向上させることができ、負荷分散サブシステム３００は、異なる対象機器の要求を、異なるデータ処理サブシステムに均等化して処理するために使用され、データ処理サブシステムは、データを処理して、処理結果を得るために使用され、システムモニタリングサブシステム６００は、データ処理システム全体の動作をモニタリングするために使用され、データ記憶サブシステム７００は、データ記憶を実現するために使用される。

しかしながら、現在データ処理を行っているデータ処理エンジンの場合、データ処理エンジンが集中配置され、複雑な構成であるため、配置及び保守に大きな保守コストが必要となり、サブシステムの一部だけに問題が発生すると、データ処理の正常な動作に影響を与える可能性がある。また、データ処理エンジンには負荷分散サービスが含まれているが、障害が発生した場合、依然としてより多くの対象機器のアクセスに影響を与える可能性があり、システム障害の障害が大きくなる。さらに、集中配置の影響により、一方では、データ処理エンジンが地理的な制限を受け、データサービス範囲の拡大を実現することが難しくなり、他方では、機能のアップグレード時にサービスを停止する必要があり、正常なサービスデータに影響を与える。また、従来技術のデータ処理エンジンは、一般的にクラウドベンダによってサービスが提供されるため、サービス機能が標準化される傾向にあり、機能拡張に限界があり、クラウドベンダが提供する機能に依存する場合が多く、利用対象者にとって独自のデータ処理機能をカスタマイズすることはできない。

また、従来技術によるデータ処理方式の場合、性能を向上させるために、データ処理エンジンは、一方向認証方式を採用することが多く、リクエスト攻撃を受けやすく、損失が避けられないため、データセキュリティリスクが存在し、データの安全な記憶が難しくなる。また、対象機器の操作ログを永続的に記憶することができないため、関連する過去データを追跡することができず、例えば、データの置換後、置換後の最新データのみが保存され、置換前の過去データを照会することはできない。さらに、対象機器は、データ処理エンジンから処理結果を得るしかできることなく、処理結果の正確性チェックができないことによって、データ処理結果の正確性を判定することができない。

上記に鑑み、本願の実施例では、データ処理方法、装置、電子機器、コンピュータ記憶媒体及びコンピュータプログラム製品を提案し、ブロックチェーンシステム内のノード機器は、対象機器から送信されたデータ処理要求を受信し、データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、処理待ちデータに対する操作タイプ情報、及び対象機器の対象識別情報を取得し、ここで、１つのコントラクト識別情報は、１つのスマートコントラクトを識別するために使用され、１つのスマートコントラクトには、少なくとも１つのデータ処理機能の処理ロジックが保存されており、次に、コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、目標スマートコントラクトにおける操作タイプ情報に対応する処理方式に従って、処理待ちデータを処理して、データ処理結果を得、その後、データ処理結果を対象機器にフィードバックする。

このようにして、対象機器のデータ処理要求に基づいてデータ処理機能を実現する際に、ブロックチェーンシステム内のノード機器及びブロックチェーンに記憶されたスマートコントラクトにより、様々なデータ処理機能を実現することができ、データ処理を遂行するためのシステム構成を簡素化し、データ処理エンジンに対する保守及び配置を、ブロックチェーンにおけるスマートコントラクトの配置及び更新に変換することで、保守及び配置の複雑度を大幅に低減することができる。また、ブロックチェーンシステムの分散アーキテクチャにより、データ処理機能の分散構築を実現することができ、データ処理の実行時に、データ処理要求に指示される目標スマートコントラクトを呼び出すことで、処理待ちデータに対して対応的にデータ処理を行うことができる。したがって、ブロックチェーンにより、ノード機器に各種データ処理機能を容易に配置することができ、これにより、データ処理機能の実現時の配置コスト及び保守コストを大幅に削減し、データ処理サービスを容易に拡張することができ、サービス拡張が地域要因によって制限される問題を解決する。さらに、ブロックチェーンシステム内の各ノード機器にブロックチェーンが記憶されている特性により、ブロックチェーンシステム内の１つのノード機器が故障した場合に、他のノード機器も同じ処理機能を実現できるため、１つのノード機器の故障によってデータ処理サービスの正常な動作に影響を与えることなく、それにより、対象機器が無感知の状態で、データ処理要求に対する正常な応答を保証することができる。また、ブロックチェーンシステムの記憶原則により、処理プロセスで生成されるデータをブロックチェーンに記憶するだけでなく、過去データの照会及び追跡も可能となるため、対象機器の視点からデータ処理結果の検証が可能となり、データの安全な記憶を保証しつつ、データ処理結果の信頼性を向上させることができる。

以下では、図面を参照して本願の好ましい実施例について説明する。理解すべきこととして、本明細書に記載の好ましい実施例は、本願を説明及び解釈するためのみに使用され、本願を限定するものではない。本願の実施例及び実施例における特徴を、矛盾することなく互いに組み合わせることができる。

図２に示すように、図２は、本願の実施例における適用可能なシーンの概略図である。この適用シーンの概略図には、対象機器２０１、及びノード機器２０２（ノード機器２０２－１～２０２－ｍを含む）が示されている。

本願の実施例では、対象機器２０１は、目標対象が位置する端末機器であり、例えば、パーソナルコンピュータ、携帯電話、タブレットＰＣ、ノート型パソコン、電子ブックリーダー、スマートホーム、及び車載端末などの一定のコンピューティング能力を有するコンピュータ機器であり得る。対象機器２０１は、目標対象の実際の処理ニーズに応じて、ブロックチェーンシステム内のノード機器２０２にデータ処理要求を送信し、ノード機器２０２によってフィードバックされるデータ処理結果を取得することができ、ここで、対象機器がアクセスするノード機器は、目標対象によって対象機器で選択されたものであってもよいし、距離情報に基づいてデフォルトでアクセスされるものであってもよいし、関連技術で端末がブロックチェーンノードにアクセスする可能な規則に従ってアクセスされるものであってもよいし、本願はこれらを限定しない。

ノード機器２０２とは、ブロックチェーンシステム内のノードを指し、独立した物理サーバであってもよいし、複数の物理サーバで構成されたサーバクラスタ又は分散システムでもあってもよいし、クラウドサービス、クラウドデータベース、クラウドコンピューティング、クラウド関数、クラウドストレージ、ネットワークサービス、クラウド通信、ミドルウェアサービス、ドメインネームサービス、セキュリティサービス、コンテンツ配信ネットワーク（ＣＤＮ：Ｃｏｎｔｅｎｔ Ｄｅｌｉｖｅｒｙ Ｎｅｔｗｏｒｋ）、ビッグデータ及び人工知能プラットフォームなどの基本的なクラウドコンピューティングサービスを提供するクラウドサーバであってもよい。

本願の実施例では、ブロックチェーンのスマートコントラクトに基づくデータ処理エンジンは、主に、基礎となるブロックチェーンシステムと、データ処理に使用されるスマートコントラクトとを含む。アーキテクチャ上、ブロックチェーンシステム内の１ノード機器（又はノード）は、主に、仮想マシン、コンセンサス、記憶、ネットワーク、及びデータ処理用のスマートコントラクトなどのモジュールを含み、ここで、ブロックチェーンシステム内のノードとなるデバイスに、ブロックチェーンシステムの機能を実現するためのノードプログラムが配置される必要があり、このノードプログラムのプログラム構造は、仮想マシン、コンセンサス、記憶、及びネットワークの４つの要素を含み、スマートコントラクトの実行環境を構築するために使用され、データの処理要求を受信し、スマートコントラクトを呼び出して処理を完了させることができ、実際の処理ニーズに応じて、処理によって生成されるデータをブロックチェーンに記憶することができる。

本願で提案する技術的解決策は、様々な適用シーンにおいて、様々なタイプのマルチメディアデータに対するデータ処理を実現することができ、関連するマルチメディアデータは、ビデオ、オーディオ、ファイル、画像などであり得る。

説明すべきこととして、対象機器によって開始されるデータ処理要求に対応する処理操作は、ファイルフォーマット変換、ファイル内容検索、ファイル編集、画像フォーマット変換、画像スケーリング、画像編集、ウォーターマーク操作、オーディオフォーマット変換、オーディオビットレート変換、オーディオ編集、ビデオフォーマット変換、ビデオ圧縮、ビデオ編集、データ照会、及びデータ統計などのいずれか１つ又は組み合わせを含むが、これらに限定されない。

様々なデータ処理ニーズに応じて、対象機器２０１は、マルチメディアデータに対する各種データ処理ニーズに基づいて、データ処理要求を開始することができ、このデータ処理要求は、処理待ちデータの記述情報、呼び出して実行すべきスマートコントラクトのコントラクト識別情報、処理待ちデータに対する操作タイプ情報、及び対象機器の対象識別情報を含む。

その後、ノード機器は、データ処理要求を受信した後、データ処理要求に含まれるコントラクト識別情報に従って、対応する目標スマートコントラクトを取得し、この目標スマートコントラクトにおいて拘束される記憶ロジックに従って、取得した処理待ちデータを処理し、対象機器２０１にデータ処理結果をフィードバックし、次に、実際の処理ニーズに応じて、データ処理結果をブロックチェーンに記憶すると決定する場合、目標スマートコントラクトの実行過程において、データ記憶インターフェースを呼び出して、ブロックチェーンシステムにおけるデータ記憶ロジックを取得し、決定したデータ記憶ロジックに従ってブロックチェーンに記憶を行う。

以下では、まず、図面を参照して、ブロックチェーンシステム内の１つのノード機器の視点から、本願の実施例に係るデータ処理プロセスについて詳細に説明する。

説明すべきこととして、本願の実施例では、ブロックチェーンに基づくデータ処理エンジンは、１つの分散型処理システムであり、ノード機器間は、一般的にポイントツーポイント（ｐ２ｐ：ｐｏｉｎｔ ｔｏ ｐｏｉｎｔ）通信ネットワークを採用し、サービスを必要とする場所でネットワークが順調である場合、１つのノード（又はノード機器）を構築すれば、データ処理サービスを提供することができ、拡張性は地理的な制限を受けない。

対象機器は、データ処理要求を開始する際に、少なくとも１つのノード機器にデータ処理要求を送信することができ、これにより、ブロックチェーンシステム内の１つのノード（又はノード機器）に障害が発生しても、システム全体の正常な動作に影響を与えることなく、他の機器でデータ処理を実行することができ、対象機器から送信されるデータ処理要求に対して、対象機器が無感知の状態で、データ処理を遂行することができる。以下の説明では、１つのノード機器が実行可能な処理プロセスを例として、データ処理プロセスについて説明する。

図３Ａに示すように、図３Ａは、本願の実施例におけるデータ処理のフローチャートである。以下では、図３Ａを参照して、本願の実施例におけるデータ処理プロセスについて詳細に説明する。

ステップ３０１において、ノード機器は、対象機器から送信されたデータ処理要求を受信し、データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、処理待ちデータに対する操作タイプ情報、及び対象機器の対象識別情報を取得する。

本願の実施例では、ノード機器は、対象機器から送信されたデータ処理要求を受信する前に、まず、ブロックチェーンシステムに加入してブロックチェーンシステム内のノードになる必要がある。

いくつかの実施例では、ブロックチェーンシステムにおけるノード配置方式に従って、ノード機器をブロックチェーンシステム内のノードとして構成し、ブロックチェーンを記憶することができ、ここで、ブロックチェーンは、異なるデータ処理機能を実現するための、記憶されたスマートコントラクトを含む。

説明すべきこととして、ブロックチェーンシステム内のノード機器について、実際の処理ニーズに応じて、いくつかの機器を選択してノードプログラムを配置することによって、ノードプログラムが配置された機器は、ブロックチェーンシステム内のノード機器とされることができ、又は、他のプラットフォームによって保守されるブロックチェーンシステムに基づいてデータ処理を行い、保守されるブロックチェーンシステム内のノード機器及び記憶されたスマートコントラクトにより、データ処理機能を実現することができる。ここで、ノードプログラムを配置することにより、ノード機器の内部に、仮想マシン、コンセンサス、記憶、ネットワーク、及びデータ処理用のスマートコントラクトなどのモジュールを持たせる。

例えば、現在国内でよく使われるＣｈａｉｎＭａｋｅｒ技術により、非常に高性能で強力なブロックチェーンシステムを簡単に構築することができ、又は、ブロックチェーンサービスを直接購入することができる。

このように、ブロックチェーンノードの処理機能を構成することにより、機器をブロックチェーンシステム内のノード機器として構築することができ、後続の対象機器のデータ処理要求に基づいてデータ処理を実現するための処理基盤を提供し、さらに、現在のブロックチェーン技術が徐々に成熟していることにより、ブロックチェーンシステムの配置及び保守は非常に簡単になり、したがって、ブロックチェーンシステムに基づいて本願が構築したデータ処理システム（又はデータ処理エンジン）は、システム構成を大幅に簡素化し、配置及び保守コストを削減することができる。

説明すべきこととして、本願の実施例では、ノード機器はブロックチェーンシステム内のノードとして、ブロックチェーンが記憶され、且つこのブロックチェーンには、様々な取引データが記憶され、及び少なくとも１つのデータ処理機能を実現する処理ロジックのスマートコントラクトが記憶され、ここで、ブロックチェーンの作成と記憶プロセス、及びスマートコントラクトの配置プロセスについて、当分野における成熟した技術であり、本願はこれらを限定しない。

例えば、スマートコントラクトを配置する際に、プログラミングによって得られるスマートコントラクトを取得した後、異なるブロックチェーンアーキテクチャにおけるスマートコントラクト配置方式に従って、スマートコントラクトのブロックチェーンに記憶を実現することができる。

ステップ３０１を実行する際に、ノード機器は、対象機器から送信されたデータ処理要求を受信することができ、ここで、前記データ処理要求は、対象機器が、所定のフィールドフォーマットに従って、処理待ちデータの記述情報及び決定されたコントラクト識別情報に基づいて構築され、コントラクト識別情報に対応する目標スマートコントラクトは、処理待ちデータに対して行われる処理ロジックを含み、次に、前記フィールドフォーマットに従ってデータ処理要求を解析して、コントラクト識別情報、処理待ちデータの記述情報、処理待ちデータに対する操作タイプ情報、及び対象機器の対象識別情報を取得し、１つのコントラクト識別情報は、１つのスマートコントラクトを識別するために使用され、１つのスマートコントラクトには、少なくとも１つのデータ処理機能の処理ロジックが保存されている。

いくつかの実施例では、対象機器によって開始されるデータ処理要求について、前記データ処理要求は、対象機器内のウェブページで、対象機器に所定のアプリケーション（ＡＰＰ：ａｐｐｌｉｃａｔｉｏｎ）で、又は、対象機器内の指定されたミニプログラムページでトリガされる。ノード機器は、対象機器とデータ処理要求のフィールドフォーマットを予め合意することができ、これにより、目標対象の視点から見れば、目標対象が位置する対象機器は、所定のフィールドフォーマットに基づいて、データ処理要求を生成することができ、ノード機器の視点からみれば、ノード機器は、所定のフィールドフォーマットに基づいて、データ処理要求を解析することにより、データ処理要求に含まれる情報内容を決定することができる。

説明すべきこととして、本願の実施例では、データ処理要求は、データをブロックチェーンに記憶するか否かの指示情報を含むことができ、スマートコントラクトに前記指示情報に対する識別文を構成し、それにより、後続のデータ処理プロセスで、指示情報及びスマートコントラクトに基づいて、ブロックチェーンに記憶が必要であると決定されたデータが記憶される。

例えば、合意によって定義される操作アルゴリズムタイプ及びデータ処理要求の要求構造形式は、
「//Operate algo definition 操作アルゴリズムを定義する
enum OpAlgo{//列挙タイプの操作アルゴリズムの定義を表す
//Document split algo ファイル分割アルゴリズムを定義する
DocSplit=0;//番号０でファイル分割アルゴリズムを表すと定義する
//Picture Compression algo 画像圧縮アルゴリズムを定義する
PicCompression=1;//番号１で画像圧縮アルゴリズムを表すと定義する
//Music Compression algo オーディオ圧縮アルゴリズムを定義する
MusicCompression=2;//番号２でオーディオ圧縮アルゴリズムを表すと定義する
//Video Rate Compression algo ビデオ圧縮率アルゴリズムを定義する
VideoRateCompression=3;//番号３でビデオ圧縮率アルゴリズムを表すと定義する
…}
message Operate{//定義された要求構造を表す
//id of data//データの識別情報を表し、処理要求対象データのブロックチェーンにおける対応するキーワード情報を表し、前記キーワード情報に基づいてブロックチェーンに記憶された値、即ち、処理待ちデータを取得することができる
DataId string=0;//データ処理要求内の番号が０である位置が処理待ちデータの識別情報を示すことを表す
//Op is the op algo for the data 番号０に示すデータタイプを処理するために採用する操作アルゴリズムを表す
Op OpAlgo=1;//処理待ちデータをデータ処理するために採用する操作アルゴリズムを表す
…//さらに、実際の処理ニーズに応じて、データ処理要求におけるスマートコントラクトのコントラクト識別情報の対応する番号位置、対象識別情報に対応する番号位置、データを記憶するか否かの指示情報が位置する番号位置なども定義することができる}」
の通りである。

このように、列挙タイプの操作アルゴリズムを定義することにより、ノード機器が実現可能なデータ処理機能に拡張性を持たせ、操作アルゴリズムの定義と配置を増加することによって、データ処理のスマートコントラクトを実現し、データ処理機能の拡張を容易に実現することができ、換言すれば、スマートコントラクトにおける処理機能の拡張を実現することに相当する。また、定義されたフィールドフォーマットにより、データ処理要求の内容を効果的に解析し、標準化された要求構造でデータの効果的な処理を実現することができる。

説明すべきこととして、本願の実施例では、処理する必要があるデータタイプ、及び実現する必要がある処理操作に応じて、複数のスマートコントラクトをそれぞれ定義することができ、又は、複数のスマートコントラクトを１つのスマートコントラクトに統一することもでき、本願はこれらを限定しない。

各スマートコントラクトについて、スマートコントラクトは、機能インターフェース層、アルゴリズム層、及び記憶層という３層の論理構造を含み、機能インターフェース層は、実現可能なデータ処理機能とデータ処理が依存するパラメータとを限定するために使用され、アルゴリズム層は、データ処理機能を実現するアルゴリズム内容を限定するために使用され、記憶層は、データ処理結果の記憶形式を限定するために使用される。換言すれば、機能インターフェース層は、スマートコントラクトがサポートする機能及び前記機能を実現するために渡すべきパラメータを表すために使用され、アルゴリズム層には、データ処理の実現に関与するデータ処理アルゴリズムが含まれ、機能層が実際の処理ニーズに応じで呼び出し、記憶層は、アルゴリズム層によって最終的に生成されるデータを記憶するために使用され、いくつかの実施例では、カプセル化されたデータ記憶インターフェースを記憶層で呼び出すことにより、ブロックチェーンシステムにおけるブロックチェーン記憶方式を採用して、データ記憶を実現することができる。

例えば、図３Ｂに示すように、図３Ｂは、本願の実施例において、記憶されている各スマートコントラクトのアーキテクチャの概略図である。図３Ｂに示す内容から分かるように、ファイル、画像、オーディオ、及びビデオなどの各種マルチメディアデータに対して、対応するデータを処理するためのスマートコントラクトをそれぞれ構築することができ、ここで、各種スマートコントラクトには同じ階層構造が含まれる。

別の例では、図３Ｃに示すように、図３Ｃは、本願の実施例におけるスマートコントラクトでサポートされる機能の概略図である。図３Ｃに示すように、スマートコントラクトの実現可能な機能は、スマートコントラクトの機能インターフェース層によって定義され、典型的な機能には、データＩＤに基づいて、対応するデータ内容を照会する操作、各種データ操作、課金統計操作などことが含まれ、ここで、データ操作はさらに、異なるデータタイプに従って複数の操作に分類することができ、例えば、フォーマット変換操作に、ファイル、画像、オーディオ、及びビデオに対するフォーマット変換がある。

説明すべきこととして、実際の処理ニーズに応じて、スマートコントラクトは、開発者によって作成された後、ブロックチェーンに配置されてもよいし、目標対象によって対象機器で作成された後、ブロックチェーンに配置されてもよいし、本願はこれらを限定しない。また、スマートコントラクトは、汎用的な３層構造を有し、関連する開発者又は目標対象が、階層的にプログラミングを行うのに便利であり、これにより、データを実現するスマートコントラクトを得ることができる。

例えば、可能な実現形態では、１つのデータ処理機能Ａを実現するスマートコントラクトを作成する際に、開発者１が機能インターフェース層の実現コードを作成し、開発者２がアルゴリズム層の実現コードを作成し、及び開発者３が記憶層の実現コードを作成することができ、さらに、開発者１～３が作成した内容を統合することにより、データ処理機能Ａを実現するスマートコントラクトを得ることができる。

このように、スマートコントラクトに対応するコード全体をブロック化することに相当し、これにより、複数の人がスマートコントラクトのプログラミングプロセスに参加できることになり、内部ロジックが明確なスマートコントラクトを構築するとともに、スマートコントラクトに対する保守にも有利になり、スマートコントラクトのプログラミング難易度だけでなく、データ処理機能の拡張難易度も低下させる。

ステップ３０２において、ノード機器はコントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、目標スマートコントラクトにおいて拘束される処理方式に従って、処理待ちデータを処理して、データ処理結果を得る。

本願の実施例では、ノード機器がデータ処理要求に含まれる対象識別情報、コントラクト識別情報、処理待ちデータに対する操作タイプ情報、及び処理待ちデータの記述情報を取得した後、ノード機器は、対象識別情報に基づいて、対象機器が身元認証に合格したと決定する場合、コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、次に、目標スマートコントラクト、対象識別情報、及び操作タイプ情報に基づいて、対象機器が操作タイプ情報に対応する操作を要求する権限を有すると決定した場合、処理待ちデータを取得し、その後、目標スマートコントラクトにおける、操作タイプ情報に対応する機能インターフェースを決定し、機能インターフェースに対応するアルゴリズム内容を呼び出して、処理待ちデータを処理する。

いくつかの実施例では、データ処理を行う前に、まず、対象機器に対して身元認証を行う必要があり、検証プロセスでは、ノード機器は、所定の身元認証インターフェースにより、ブロックチェーン内部の身元認証処理ロジックを呼び出して、対象機器に対する署名検証を実現することができる。ここで、異なるブロックチェーンシステムアーキテクチャで実行されるブロックチェーンの身元認証ロジックは異なる場合があり、本願は、関連技術におけるブロックチェーンシステムで署名検証を行う処理ロジックを踏襲して、処理前の身元認証を実現する。

このように、ブロックチェーンのメカニズムは、一般的に双方向認証であるため、対象機器のすべての要求は、一般的に取引としてチェーンに記録され、すべての取引は、対象機器の署名があり、ノード機器は、ブロックチェーンシステムにおける認証ロジックに従って、対象機器が署名検証に合格してからこそ対象機器にサービスを提供することを決定する。それにより、ノード機器への攻撃がより困難になり、仮に攻撃が発生しても署名検証を行うことにより、正常なサービストラフィックであるか、それとも攻撃トラフィックであるかを決定することができるため、無駄なサービスコストを削減し、ブロックチェーンに基づいて構築されたデータ処理エンジンへの攻撃の影響を低減することができる。

その後、ノード機器は、対象機器が身元認証に合格したと決定する場合、コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索する。ここで、ブロックチェーンにおける内容の記憶形式が、通常、キーワード－キー値（ｋｅｙ－ｖａｌｕｅ）の形式であるため、コントラクト識別情報を取得したことは、スマートコントラクトを検索できるキーワードを取得したことに相当し、さらに、コントラクト識別情報をキーワードとするキー値の内容を検索することにより、目標スマートコントラクトを照会して決定することができる。

さらに、ノード機器は、目標スマートコントラクト、対象識別情報、及び操作タイプ情報に基づいて、対象機器が操作タイプ情報に対応する操作を開始する権限を有すると決定した場合、処理待ちデータを取得する。

いくつかの実施例では、ノード機器は、ブロックチェーンシステムレベルでの身元認証を完了した後、決定された目標スマートコントラクトに基づいて処理を行う前に、目標スマートコントラクト内部の権限認証ロジックにより、対象機器が操作タイプ情報によって指示される操作を要求する権限を有するか否かを検証し、対象機器が対応する操作の提供を要求する権限を有すると決定した場合、処理待ちデータを取得する。

説明すべきこととして、ノード機器にサービスを要求できる対象機器は、すべてブロックチェーンシステムに予め登録済みの対象機器であるため、ノード機器は、対象機器に対して操作を要求する権限を構成することができる。これに基づき、実際の処理ニーズに応じて、スマートコントラクトは、対象と、対象が要求できる操作権限との対応関係を定義することができる。

例えば、スマートコントラクトでは、ブロックチェーンシステムに登録されている対象セットを維持することができ、対象セット内の対象は、ノード機器にサービス提供を要求することができる。対象セット内の各対象には、対象が提供を要求できる処理操作を表すための、対応する操作権限セットが存在する。

別の例では、対象１がデータ圧縮サービスを購入したと決定した場合、対象１は、オーディオデータ圧縮操作を要求する権限を有する。これに基づき、対象１がオーディオデータ圧縮要求を開始する場合、ノード機器は、データ圧縮機能を実現する目標スマートコントラクトを呼び出して、取得したオーディオデータに基づいてオーディオデータ圧縮を実現することができる。

このように、ノード機器が署名検証を完了した後、目標スマートコントラクトの内部で、対象機器に対する権限検証を実現することに相当し、対象機器に対するサービス要求認証を実現することに相当し、対象機器に権限のないサービスを提供することを避ける。

説明すべきこととして、ノード機器が処理待ちデータを取得する際に、実際に可能な異なる実現シーンに応じて、以下の２つの取得方式が存在する。

方式１において、データ処理要求に含まれる処理待ちデータを取得する。

本願の実施例では、データ処理要求に含まれる記述情報が処理待ちデータの内容を記述するために使用される場合、ノード機器は、記述情報に基づいて決定されるデータ内容を、取得した処理待ちデータとして決定する。

いくつかの可能な実現シーンでは、対象機器が処理要求された処理待ちデータが占める記憶空間が大きくなく、且つ処理待ちデータがブロックチェーンに予め記憶されていない場合、ノード機器が受信したデータ処理要求は処理待ちデータを直接含むことができる。このとき、受信した処理待ちデータの記述情報は、処理待ちデータの内容を記述するために使用されるため、データ処理要求に含まれる処理待ちデータを直接取得することができる。

方式２において、データ処理要求内の記述情報に基づいて、処理待ちデータを照会して取得する。

本願の実施例では、データ処理要求に含まれる記述情報がブロックチェーン内に記憶されているデータ内容の決定を指示するために使用される場合、記述情報に基づいてブロックチェーンから検索して得られたデータ内容を、取得した処理待ちデータとして決定し、又は、前記記述情報が処理待ちデータの記憶アドレスを記述するために使用される場合、記憶アドレスに基づいて取得したデータを、処理待ちデータとして決定する。

いくつかの実施例では、いくつかの可能な実現シーンでは、処理要求された処理待ちデータがブロックチェーン内に予め記憶されたデータである場合、ノード機器が取得した記述情報は、ブロックチェーンにおける処理待ちデータに対応するキーワード（ｋｅｙ）を表すことができ、これにより、キーワードに基づいて処理待ちデータ（即ち、ｋｅｙに対応するｖａｌｕｅ）を取得することができる。

いくつかの可能な実現シーンでは、対象機器によって処理要求された処理待ちデータが占める記憶空間が大きく、処理待ちデータがブロックチェーンに予め記憶されていなく、且つ対象機器が処理待ちデータをブロックチェーンに記憶すると指示した場合、ノード機器は、まず、処理待ちデータのブロックチェーン記憶のためのデータ処理要求に基づいて、データ記憶機能を実現する目標スマートコントラクトを呼び出して、目標スマートコントラクトにおけるデータ記憶機能を実現する処理ロジックに基づいて、処理待ちデータのブロックチェーンへの記憶を実現し、処理待ちデータのブロックチェーンに記憶時に対応するｋｅｙ値情報を対象機器にフィードバックする。さらに、ノード機器は、処理待ちデータに対するデータ処理要求に応答して、データ処理要求に含まれる記述情報（即ち、ｋｅｙ値）を決定し、その後、ノード機器は、記述情報に対応するｖａｌｕｅ値を検索することにより、処理待ちデータを決定し、ここで、ｖａｌｕｅ値は、処理待ちデータが記憶されているアドレス情報を指す場合があり、この場合、ノード機器は、取得したアドレス情報に基づいて処理待ちデータ取得する必要がある。

別のいくつかの可能な実現シーンでは、対象機器によって処理要求された処理待ちデータが占める記憶空間が大きく、対象機器が処理待ちデータをブロックチェーンに記憶しないと指示し、且つ処理待ちデータがブロックチェーンに予め記憶されていない場合、ノード機器が受信したデータ処理要求に含まれる記述情報は、処理待ちデータが記憶されているアドレス情報を指し、この場合、ノード機器は、アドレス情報に基づいて処理待ちデータを取得する必要がある。

説明すべきこととして、本願の実施例では、占める記憶空間の大きさを判定する際に、処理待ちデータが占める空間と設定値との関係に基づいて判定でき、占める空間が設定値より大きいと決定した場合、占める記憶空間が大きいと判定でき、占める空間が設定値より小さい場合、占める記憶空間が大きくないと判定することができる。ブロックチェーンに記憶されている内容はｋｅｙ－ｖａｌｕｅの形式であり、これにより、記述情報をｋｅｙとして、対応するキー値を検索して決定することができ、それによって、検索して得たキー値に基づいて、処理待ちデータを得ることができる。

また、占める記憶空間が大きい処理待ちデータをブロックチェーンに記憶する際に、処理待ちデータを記憶するために大きな記憶空間が必要である場合、実際の処理ニーズに応じて、ノード機器は、処理待ちデータの内容を指定クラウドなどの機器に記憶するように対象機器に指示することができ、対象機器が送信するデータ処理要求は、処理待ちデータの記憶位置を表すＵＲＬ（ｕｎｉｆｏｒｍ ｒｅｓｏｕｒｃｅ ｌｏｃａｔｏｒ）を含むことができ、さらに、データ記憶要求を処理する際に、ノード機器は、指定されたデータ記憶スマートコントラクトにおけるデータ記憶機能インターフェースに対応する処理ロジックを採用して、関連技術における成熟したデータブロックチェーン記憶方式を呼び出し、構築されたｋｅｙ－ｖａｌｕｅ、及び定義された辞書内容をブロックチェーンに記憶する。ここで、処理待ちデータによって生成されたデータ識別情報（データＩＤと表記）をｋｅｙとし、処理待ちデータに対応するＵＲＬを、ｋｅｙに対応するｖａｌｕｅとし、辞書内容は、ブロックチェーン記憶のデータ構造を定義し、ブロックチェーンへの記憶時にどのようなデータ構造に従って記憶しているかを指示するために使用され、即ち、ｋｅｙとｖａｌｕｅとの対応関係を定義する。

説明すべきこととして、本願の実施例では、辞書内容におけるキーワード（ｋｅｙ）は、データＩｄ（即ち、データを一意に識別できる情報）であり得、辞書内容における値（ｖａｌｕｅ）は、特定の構造に従ってデータ直列化した後に得られるバイトの配列であり得る。辞書内容内で、すべてのタイプのデータに対応する特定構造を定義することができ、且つこれらの構造は、データ直列化プロトコル（ｐｒｏｔｏｂｕｆ：Ｇｏｏｇｌｅ Ｐｒｏｔｏｃｏｌ Ｂｕｆｆｅｒｓ）を使用して統一的に定義し、実際の処理ニーズに応じて、記憶されているデータタイプを調整することができる。

例えば、典型的なデータ構造形式は、
「//datatype definition データタイプの定義を表す
enum DataType{//列挙タイプのデータタイプの定義を表す
//Document type of data ファイルタイプを表すデータ
Document=0;//文字０でファイルタイプを示すデータを表す
//Picture type of data 画像タイプを表すデータ
Picture=1;//文字１で画像タイプを示すデータを表す
//Music type of data オーディオタイプを表すデータ
Music=2;//文字２でオーディオタイプを示すデータを表す
//Video type of data ビデオタイプを表すデータ
Video=3;//文字３でビデオタイプを示すデータを表す
…}
message Data{//記憶されたｖａｌｕｅ内のデータ構造を表す
//DataType for data field データタイプのために予約したデータ領域を表す
DataType data_type=0 //データ構造内の番号０の位置に記憶されているデータタイプ情報を表す
//The field “data” is used to hold the binary data to process or store この位置が処理後のバイナリデータ又は記憶しようとするバイナリデータを保存するために使用されることを表す
bytes data=1;//データ構造内の番号１の位置にデータ内容が記憶されていることを表す}
の通りである。

別の例では、１つのオーディオデータをブロックチェーンに記憶する必要があると仮定すると、辞書内容から分かるように、前記オーディオデータをブロックチェーンに記憶する際の構造形式は、オーディオデータＩＤ－｛２；バイナリ形式のオーディオデータ内容｝であり、ここで、文字２は、オーディオタイプを表す。

このように、データ記憶に対して拡張性を有するデータタイプを定義し、且つ処理待ちデータに対してデータ処理を実現するスマートコントラクトを指定することにより、指定されたスマートコントラクトを呼び出してデータ処理操作を実行する際に、異なるデータタイプに応じて、対応する処理アルゴリズムを呼び出してデータ処理を容易に行うことができ、データ処理効率を向上させることができる。

また、上記の方式１及び方式２に示した処理待ちデータの取得方式と組み合わせることにより、様々なシーンで処理待ちデータを効果的に取得することができる。

いくつかの実施例では、処理機器は、目標スマートコントラクトにおける操作タイプ情報に対応する機能インターフェースを決定し、前記機能インターフェースに対応するアルゴリズム内容を呼び出して、処理待ちデータを処理して、データ処理結果を得る。

本願の実施例では、スマートコントラクトに基づいて実現可能な少なくとも１つの処理機能を表すために、１つのスマートコントラクトに少なくとも１つの機能インターフェースが含まれる可能性があることを考慮すると、呼び出すべき機能インターフェースを決定するために、データ処理要求に操作タイプ情報が含まれる。ここで、スマートコントラクトの機能インターフェース層には、前記スマートコントラクトを呼び出すことで実現可能な機能が定義され、機能インターフェース層における機能インターフェースにより、スマートコントラクトのアルゴリズム層におけるアルゴリズムを呼び出すことができる。その後、ノード機器は、前記機能インターフェースに対応するアルゴリズム内容を呼び出すことにより、処理待ちデータを処理して、データ処理結果を得る。

このように、データ処理要求に基づいて目標スマートコントラクト及び操作タイプを決定した後、目標スマートコントラクトにより、対象機器の認証が合格したと決定した場合にデータ処理サービスを提供することにより、ブロックチェーンシステムの分散型アーキテクチャにより、各ノード機器にデータ処理機能を提供することができ、対象機器のデータ処理要求に対して効果的な応答を行い、データ処理の安定した進行を保証することができる。

ステップ３０３において、ノード機器は、データ処理結果を対象機器にフィードバックする。

いくつかの実施例では、取得したデータ処理結果について、ノード機器は、目標スマートコントラクトを実行する際に、データ処理要求に含まれる、データ処理結果を記憶するか否かを指示する指示情報に基づいて、データ処理結果を記憶する必要があるか否かを決定する。これに基づき、ノード機器がデータ処理結果をフィードバックするプロセスには、以下の２タイプの操作がある。

本願の実施例では、対象機器のデータ処理要求に、経過データ及びデータ処理結果を記憶するか否かを指示する指示情報が含まれ、スマートコントラクトに前記フィールドを識別する文を構成すると予め定めることができ、それにより、前記フィールドの異なる値に基づいて、異なる処理内容を実行することができる。

タイプ１において、対象機器にデータ処理結果を直接フィードバックする。

本願の実施例では、ノード機器は、データ処理要求に基づいてデータ処理結果を記憶しないと決定した場合、取得したデータ処理結果を対象機器に直接フィードバックする。

いくつかの実施例では、ノード機器は、目標スマートコントラクトを実行する際に、データ処理結果を記憶する必要がないと決定した場合、処理して得られるデータ処理結果を対象機器に直接フィードバックすることができる。

タイプ２において、対象機器にデータ処理結果をフィードバックし、データ処理結果に対してデータ識別情報を生成し、データ識別情報及び対応するデータ処理結果をブロックチェーンに記憶する。

本願の実施例では、ノード機器は、データ処理要求に基づいてデータ処理結果を記憶すると決定した場合、取得したデータ処理結果生に対して対応するデータ識別情報を生成し、データ処理結果を対象機器にフィードバックし、及びブロックチェーンコンセンサスの原則に従って、データ識別情報及び対応するデータ処理結果を、ブロックチェーンシステム内の各ノード機器に記憶する。

いくつかの実施例では、ノード機器は、目標スマートコントラクトを実行する際に、データ処理結果を記憶する必要があると決定した場合、処理して得られるデータ処理結果を対象機器にフィードバックするとともに、前記データ処理結果に対して対応するデータ識別情報を生成し、その後、目標スマートコントラクトを実行する際に、データ記憶インターフェースを呼び出すことにより、ブロックチェーンシステムにおけるブロックチェーン記憶方式を採用するように要求し、ブロックチェーンコンセンサスの原則に従って、データ識別情報及び対応するデータ処理結果を、ブロックチェーンシステム内の各ノード機器に記憶する。ここで、データブロックチェーン記憶方式は、当分野における成熟した技術であり、本願はこれについて説明しない。

また、説明すべきこととして、ブロックチェーンシステムの記憶原則について、生成されたすべてのデータ処理操作は、通常、取引の形式で記憶されるため、すべての過去操作データは追跡でき、この部分の過去操作データの記憶は、対象機器の構成の影響を受けず、対象機器は、処理で生成されたデータ（経過データ及び処理結果データなど）を記憶するか否かを構成することができ、過去操作データの記憶について、ブロックチェーンシステムにおける記憶ロジックを呼び出すことによって実現することができ、本願はこれらを限定しない。

例えば、ユーザ１がビデオ編集を要求し、且つ編集結果を記憶しないことを指示すると仮定すると、ブロックチェーンシステムの記憶原則に従って、ユーザ１のビデオ編集操作の過去操作情報は記憶されるが、最終的な編集結果は記憶されない。

このように、対象機器の構成の記憶ニーズに応じて、対象機器が指示して記憶したデータ内容を記憶することができ、これにより、異なる対象の記憶ニーズに応じて差別的に処理することができる。

説明すべきこととして、本願の実施例では、データ処理機能の調整及びアップグレードは、スマートコントラクトをアップグレード及び配置することにより実現することができる。換言すれば、ブロックチェーンシステムのデータ処理エンジンに対して機能アップグレードする際に、対応するスマートコントラクトのみをアップグレードすればよく、また、スマートコントラクトのアップグレードプロセスで、アップグレードされる機能に対応するスマートコントラクトと他の機能に対応するスマートコントラクトのサービスに影響を受けない。スマートコントラクトのアップグレードにおいて、前記スマートコントラクトアップグレード取引とこのコントラクトを呼び出す他の取引は依存関係を有するため、ブロックチェーンシステムは、関連する各取引（又はデータ処理要求）を自動的に並び替え、順番に実行し、それにより、すべての取引が正確に実行できる効果が得られる。

いくつかの実施例では、ノード機器は、目標データ処理機能に対する機能調整処理要求を受信し、機能調整処理要求に含まれる、調整後の処理ロジックを含む記憶待ちスマートコントラクトを取得し、目標データ処理機能と他のデータ処理要求との依存関係に基づいて、受信した各データ処理要求を並び替え、並び替え結果に基づいて各データ処理要求を処理する。

また、１つのスマートコントラクトは、前記スマートコントラクトを呼び出す異なる取引に、互いに依存関係がある（同じデータを処理する）場合があれば、依存関係がない（完全に異なるデータを処理する）場合もあり、いずれの場合も、このスマートコントラクトがアップグレードされているかどうかにかかわらず、取引間の実行関係に影響を与えない。

同じスマートコントラクトを呼び出すすべての取引間に依存関係なないと仮定すると、図３Ｄに示すように、図３Ｄは、本願の実施例におけるデータ処理取引の実行順序の比較図である。図３Ｄに示すように、コントラクトアップグレードが存在しない場合、各データ処理取引（データ処理要求）は並列に実行されるが、コントラクトアップグレードが存在する場合、コントラクトアップグレード取引とデータ処理取引とは直列に実行され、データ処理取引間は並列に実行される。

このようにして、異なるデータ処理要求の実行順序を決定することができ、これはデータ照会及び操作プロセス、トラステッドコンピューティングシーンでのデータ処理プロセス、及びコントラクトアップグレード取引とデータ処理取引を並列した処理プロセスの実行順序をそれぞれ指示することに相当し、ブロックチェーンシステムにおける自動並び替え機能に基づいて、各種取引を順序良く実行することができ、これにより、処理機能のアップグレード時に、データ処理を中断することはない。

本願の実施例で提案されるデータ処理方案はさらに、トラステッドコンピューティングを行うシーンに適用され得、ノード機器の場合、ノード機器には、トラステッドコンピューティングを実行するためのトラステッドコンピューティング環境が構成されている。ここで、トラステッドコンピューティング環境の構成は、当分野における慣用技術であり、本願はこれらを限定しない。

トラステッドコンピューティングを必要とするデータ処理タスクの場合、異なるセキュリティレベルに応じて、ブロックチェーンに基づく２つの処理方案があり得る。第１の処理方案は、スマートコントラクトの配置及び呼び出しの両方が、トラステッドコンピューティングサービスに直接サクセスして、トラステッドコンピューティングを実行し、次に、計算して生成されるデータ及びデータＩＤをチェーンに記憶することであり、第２の処理方案は、スマートコントラクトの配置及び呼び出しはブロックチェーンを介して実行されるが、最終的にコントラクトの実行は、トラステッドコンピューティング環境を介して行うことである。

説明すべきこととして、ノード機器と目標対象の対象機器との間には、データの暗号化方式と復号化方式が合意され、これにより、ノード機器は、対象機器から送信された暗号化データを復号化することができる。

第１の処理方案の場合、ノード機器は、対象機器が暗号化データに対してトリガしたトラステッド処理要求を受信し、トラステッド処理要求に含まれる暗号化データ、暗号化スマートコントラクト、暗号化データに対するトラステッド操作タイプ情報、及び対象機器の対象識別情報を取得し、次に、構築されたトラステッドコンピューティング環境で、暗号化スマートコントラクトに基づいて復号化し、対応するトラステッドスマートコントラクトを取得し、対象機器がトラステッドコンピューティングタイプ情報に対応する操作を要求する権限を有すると決定した場合、暗号化データに基づいて復号化して、目標データを取得し、トラステッドスマートコントラクトにおいて拘束されるトラステッドコンピューティングロジックを採用して、目標データを処理して、トラステッドコンピューティング結果を得、その後、トラステッドコンピューティング結果をブロックチェーンに記憶し、トラステッドコンピューティング結果に対応するキーワード情報を対象機器にフィードバックする。

いくつかの実施例では、第１の処理方案において、ノード機器は、トラステッド処理要求に含まれる暗号化データ、暗号化スマートコントラクト、対象機器の対象識別情報、暗号化データに対するトラステッドコンピューティングタイプ情報を取得した後、トラステッドコンピューティング環境では、以下の操作、即ち、暗号化スマートコントラクトを復号化し、復号化後のトラステッドスマートコントラクト、対象機器の対象識別情報、及びトラステッドコンピューティングタイプ情報に基づいて、対象機器がトラステッドコンピューティングタイプに対応する操作を要求する権限を有すると決定した場合、暗号化データを復号化して目標データを取得するステップと、トラステッドスマートコントラクト内の、トラステッドコンピューティングタイプ情報と一致するトラステッドコンピューティングロジックを採用し、アルゴリズムを呼び出して目標データの処理を実現して、トラステッドコンピューティング結果を得るステップと、を実行する。

いくつかの実施例では、ブロックチェーンに記憶プロセスにおいて、ノード機器がトラステッドコンピューティング環境でトラステッドスマートコントラクトを実行して、トラステッドコンピューティング結果を得た後、引き続きトラステッドスマートコントラクトを介してデータ記憶インターフェースを呼び出すことにより、ブロックチェーンシステムにおけるデータ記憶方式を採用してデータのブロックチェーンに記憶を実現することができる。

例えば、図４Ａに示すように、図４Ａは、本願の実施例におけるトラステッドコンピューティング処理の実現プロセスの概略図である。以下では、図４Ａを参照して、関連対象のグランドを取得した場合、プライベートデータに基づいて、トラステッドコンピューティングを行うプロセスについて説明する。

ステップ４１において、対象機器は、暗号化プライベートデータ、暗号化プライベートコントラクト、対象機器の識別情報、及びトラステッドコンピューティングタイプ情報を含むプライベートデータコンピューティング要求をノード機器に送信する。

ステップ４２において、ノード機器は、プライベートデータコンピューティング要求に含まれる内容を、トラステッドコンピューティング環境に送信する。

ステップ４３において、ノード機器は、トラステッドコンピューティング環境で、暗号化プライベートコントラクトを復号化して、プライベートコントラクトを得る。

ステップ４４において、ノード機器は、トラステッドコンピューティング環境で、プライベートコントラクトにおける対象情報とトラステッドコンピューティングタイプとの対応関係に基づいて、対象機器がトラステッドコンピューティングタイプ情報に対応する操作を開始する権限を有すると決定する。

ステップ４５において、ノード機器は、トラステッドコンピューティング環境で、暗号化データを復号化して、目標データを得、コントラクトエンジンを呼び出してプライベートコントラクトを実行する。

ステップ４６において、ノード機器は、トラステッドコンピューティング環境で、トラステッドコンピューティング結果に対して一意のデータＩＤを生成し、データＩＤ及び対応するトラステッドコンピューティング結果をブロックチェーンに記憶する。

いくつかの実施例では、プライベートコントラクト内の、記憶層にカプセル化されたデータ記憶インターフェースを呼び出すことにより、ブロックチェーンシステムにおけるデータ記憶を行うための処理ロジックを取得し、ブロックチェーンに記憶を実現することができる。

ステップ４７において、ノード機器は、トラステッドコンピューティング環境で、データＩＤを対象機器にフィードバックする。

このように、トラステッドコンピューティングのニーズに応じて暗号化後のスマートコントラクト及び処理待ちデータ、及び指示されたトラステッドコンピューティングタイプを取得することにより、トラステッドコンピューティング環境で効果的な処理を実現し、データ処理の安全性を保証することができる。

第２の処理方案の場合、トラステッドコンピューティング環境で実行すべきスマートコントラクトは、暗号化されてブロックチェーンに記憶され、処理すべきデータ内容も予め暗号化されてブロックチェーンシステムに記憶され、この場合、図３Ａに示す正常のデータ処理プロセスに従ってデータ処理を行うことができる。

この場合、ノード機器が、トラステッドコンピューティングを行うように構成され、データ処理要求が暗号化データに対してトラステッド処理を行うために使用される場合、データ処理要求内のコントラクト識別情報は、ブロックチェーン内の、暗号化して記憶されたトラステッドスマートコントラクトを識別するために使用され、記述情報は、暗号化して記憶された目標データを記述するために使用され、操作タイプ情報は、要求されたトラステッドコンピューティングタイプ情報を表し、さらに、トラステッドコンピューティングを行う際に、ノード機器は、構築されたトラステッドコンピューティング環境で、暗号化して記憶されたトラステッドスマートコントラクトを復号化して、トラステッドスマートコントラクトを取得し、対象機器がトラステッドコンピューティングタイプ情報に対応する操作を要求する権限を有すると決定した場合、暗号化して記憶された目標データを復号化して、目標データを取得し、トラステッドスマートコントラクトにおいて拘束されるトラステッドコンピューティングロジックに従って、目標データを処理する。

例えば、図４Ｂに示すように、図４Ｂは、本願の実施例におけるトラステッドコンピューティング処理の別の実現プロセスの概略図である。以下では、図４Ｂを参照して、関連対象のグランドを取得した場合、プライベートデータ基づいて、トラステッドコンピューティングを行うプロセスについて説明する。

ステップ４ｂ－１において、対象機器は、暗号化プライベートコントラクトのコントラクト識別情報、暗号化データの記述情報、対象機器の対象識別情報、及びトラステッドコンピューティングタイプ情報を含むプライベートデータコンピューティング要求をノード機器に送信する。

ステップ４ｂ－２において、ノード機器は、プライベートデータコンピューティング要求に含まれる内容を受信し、コントラクト識別情報及び記述情報に基づいて、暗号化プライベートコントラクト及び暗号化データを取得する。

ステップ４ｂ－３において、ノード機器は、トラステッドコンピューティング環境で、暗号化プライベートコントラクトを復号化して、プライベートコントラクトを得る。

ステップ４ｂ－４において、ノード機器は、トラステッドコンピューティング環境で、プライベートコントラクトにおける対象情報とトラステッドコンピューティングタイプとの対応関係に基づいて、対象機器がトラステッドコンピューティングタイプ情報に対応する操作を要求する権限を有すると決定する。

ステップ４ｂ－５において、ノード機器は、トラステッドコンピューティング環境で、暗号化データを復号化して、目標データを得、コントラクトエンジンを呼び出してプライベートコントラクトを実行する。

ステップ４ｂ－６において、ノード機器は、トラステッドコンピューティング環境で、トラステッドコンピューティング結果に対して一意のデータＩＤを生成し、データＩＤ及び対応するトラステッドコンピューティング結果をブロックチェーンに記憶する。

いくつかの実施例では、プライベートコントラクト内の、記憶層にカプセル化されたデータ記憶インターフェースを呼び出すことにより、ブロックチェーンシステムにおけるデータ記憶を行うための処理ロジックを取得し、ブロックチェーンに記憶を実現することができる。

ステップ４ｂ－７において、ノード機器は、トラステッドコンピューティング環境で、データＩＤを対象機器にフィードバックする。

このように、トラステッドコンピューティングの実現ステップを、通常のデータ処理プロセスに統合することにより、ブロックチェーンに暗号化して記憶されたスマートコントラクト及び目標データに基づいて、トラステッドコンピューティングを実現することができる。

次に、例を挙げて様々なデータ処理プロセスにおいて、スマートコントラクトを呼び出して照会及び操作処理を実行するプロセスについて説明する。

図５に示すように、図５は、本願の実施例におけるスマートコントラクトを呼び出して取引を実行するフローチャートである。以下では、図５を参照して、照会及び操作を呼び出すプロセスについて説明する。

ステップ５０１において、対象機器は、データ処理要求を構築する。

ステップ５０２において、ノード機器は、データ処理要求を受信し、データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、操作タイプ情報、及び対象識別情報を取得する。

ステップ５０３において、ノード機器は、対象機器に対して署名検証を行い、対象機器の身元認証に成功したと決定する。

ステップ５０４において、ノード機器は、コントラクト識別情報に基づいて、ブロックチェーン内で、実行すべき目標スマートコントラクトを検索する。

ステップ５０５において、ノード機器は、対象機器が操作タイプ情報に対応する操作を要求する権限を有するか否かを決定し、有する場合、ステップ５０７を実行し、有しない場合、ステップ５０６を実行する。

ステップ５０６において、ノード機器は、対象機器に処理失敗の指示情報をフィードバックする。

ステップ５０７において、ノード機器は、記述情報に基づいて、ブロックチェーン内で、処理待ちデータを検索する。

ステップ５０８において、ノード機器は、操作タイプ情報に基づいて、目標スマートコントラクトで、呼び出されるべき機能関数名称を決定し、機能関数を呼び出す。

ステップ５０９において、ノード機器は、決定した機能関数に基づいて、対応するアルゴリズムを呼び出してデータ処理を行い、データ処理結果を得る。

ステップ５１０において、ノード機器は、対象機器がデータ処理結果を記憶することを指示した否かを決定し、指示した場合、ステップ５１２を実行し、そうでない場合、ステップ５１１を実行する。

ステップ５１１において、ノード機器は、対象機器にデータ処理結果を送信する。

ステップ５１２において、ノード機器は、データ処理結果に対してデータＩＤを生成し、データＩＤをキーワード情報とし、コンセンサスでブロックパッキング、検証、及びサブミットが完了した後、データＩＤ及び対応するデータ処理結果をブロックチェーンに記憶する。

ステップ５１３において、ノード機器は、対象機器にデータ処理結果及びデータＩＤをフィードバックする。

以上により、本願によって提案されるデータ処理方案では、ブロックチェーンのスマートコントラクトに基づくデータ処理エンジンの全体的なアーキテクチャを提案し、各スマートコントラクトは汎用性のあるコントラクト階層構造を有し、開発者が階層別にプログラミングすることを容易であり、スマートコントラクトを実行することによってデータ処理機能を実現する。また、記憶するデータタイプについて、拡張性を有するデータタイプの定義を与えることで、データ処理機能を実現するスマートコントラクトが、異なるデータタイプに応じて対応する処理アルゴリズムを呼び出してデータ処理を行うことができる。さらに、データ処理機能を実現するスマートコントラクトは、その機能層インターフェースの定義が拡張性を有し、実際の処理ニーズに応じて新しい機能の追加をプログラミングして実現することができる。また、拡張性を有するデータ操作タイプの定義を与えることにより、対象機器は、データ処理要求の要求構造を定義することができ、そのため、データＩＤが指定されたデータに対して、指定されたアルゴリズムを使用してデータ処理を行うことができ、また、ブロックチェーンシステムにおける取引並び替え機能により、データ照会及び操作プロセス、トラステッドコンピューティングシーンにおけるデータ処理プロセス、コントラクトアップグレード取引とデータ処理取引が並行している状態の処理順序を与えることができる。

また、データ処理機能のアップグレードはサービスに影響を与えず、ブロックチェーンに基づくデータ処理エンジンの実際のデータ処理はスマートコントラクトを使用して実現され、コントラクトアップグレードは、データのブロックチェーン記憶、データ処理などの要求と同レベルの操作として実行されるため、サービスの運営に影響を与えることなく、サービスが無感知の状態で遂行することができる。また、関連対象は、データ処理機能を実現するスマートコントラクトを作成することにより、ブロックチェーンに基づいて、配置がオーダーメイドされるデータ処理アルゴリズムを実現することができ、機能拡張は制限されない。さらに、ブロックチェーンシステムにおいて過去データが追跡可能である特性により、ブロックチェーンに基づくデータ処理エンジンのデータ処理に関するすべての操作が取引の形式で記憶し、それにより、すべての過去データは追跡することができ、関連対象は、ノード機器から操作ログを照会し、データ統計と課金を自ら実現することができる。また、ブロックチェーンシステムでデータ記憶のセキュリティが高いため、データセキュリティリスクがなく、データに敏感な特殊なシーンでは、データとコントラクトを暗号化してブロックチェーンに保存する方案、又は、スマートコントラクトと目標データをトラステッドコンピューティングで直接実行する方案を選択して、データセキュリティを保護することができる。

同じ技術的構想に基づいて、図６に示すように、図６は、本願の実施例におけるデータ処理装置の論理構造を示す模式図である。データ処理装置６００は、受信ユニット６０１と、処理ユニット６０２と、フィードバックユニット６０３と、を備え、
受信ユニット６０１は、対象機器から送信されたデータ処理要求を受信し、データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、処理待ちデータに対する操作タイプ情報、及び対象機器の対象識別情報を取得するように構成され、１つのコントラクト識別情報は、１つのスマートコントラクトを識別するために使用され、１つのスマートコントラクトには、少なくとも１つのデータ処理機能の処理ロジックが保存され、処理ユニット６０２は、コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、目標スマートコントラクトにおける操作タイプ情報に対応する処理方式に従って、処理待ちデータを処理して、データ処理結果を得るように構成され、フィードバックユニット６０３は、データ処理結果を対象機器にフィードバックするように構成される。

いくつかの実施例では、各スマートコントラクトは、機能インターフェース層、アルゴリズム層、及び記憶層という３層の論理構造を含み、機能インターフェース層は、実現可能なデータ処理機能とデータ処理が依存するパラメータとを限定するために使用され、アルゴリズム層は、データ処理機能を実現するアルゴリズムの内容を限定するために使用され、記憶層は、データ処理結果の記憶形式を限定するために使用される。

いくつかの実施例では、ノード機器がトラステッドコンピューティングを行うように構成され、データ処理要求が暗号化データに対してトラステッド処理を行うように要求するために使用される場合、コントラクト識別情報は、ブロックチェーン内の、暗号化して記憶されたトラステッドスマートコントラクトを識別するために使用され、記述情報は、暗号化して記憶された目標データを記述するために使用され、操作タイプ情報は、要求されたトラステッドコンピューティングタイプ情報を表し、
コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、目標スマートコントラクトにおける操作タイプ情報に対応する処理方式に従って、処理待ちデータを処理する際に、処理ユニット６０２は、構築されたトラステッドコンピューティング環境で、暗号化して記憶されたトラステッドスマートコントラクトを復号化して、トラステッドスマートコントラクトを取得し、対象機器がトラステッドコンピューティングタイプ情報に対応する操作を要求する権限を有すると決定した場合、暗号化して記憶された目標データを復号化して、目標データを取得し、トラステッドスマートコントラクトにおいて拘束されるトラステッドコンピューティングロジックに従って、目標データを処理するように構成される。

いくつかの実施例では、ノード機器がトラステッドコンピューティングモードでデータ処理を行うように構成される場合、データ処理装置は、コンピューティングユニット６０４をさらに備え、コンピューティングユニット６０４は、対象機器が暗号化データに対してトリガしたトラステッド処理要求を受信し、トラステッド処理要求に含まれる暗号化データ、暗号化スマートコントラクト、暗号化データに対するトラステッドコンピューティングタイプ情報、及び対象機器の対象識別情報を取得し、構築されたトラステッドコンピューティング環境で、暗号化スマートコントラクトに基づいて復号化して、対応する目標スマートコントラクトを取得し、対象機器がトラステッドコンピューティングタイプ情報に対応する操作を要求する権限を有すると決定した場合、暗号化データに基づいて復号化して、目標データを取得し、及び目標スマートコントラクトにおいて拘束されるトラステッドコンピューティングロジックを採用して、目標データを処理して、トラステッドコンピューティング結果を得、トラステッドコンピューティング結果をブロックチェーンに記憶し、トラステッドコンピューティング結果に対応するキーワード情報を対象機器にフィードバックするように構成される。

いくつかの実施例では、対象機器から送信されたデータ処理要求を受信する前に、受信ユニット６０１は、ブロックチェーンシステムにおけるノード配置方式に従って、ノード機器をブロックチェーンシステム内のノードとして構成し、異なるデータ処理機能を実現するためのスマートコントラクトを記憶するように構成される。

いくつかの実施例では、対象機器から送信されたデータ処理要求を受信し、データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、及び対象機器の対象識別情報を取得する際に、受信ユニット６０１は、対象機器から送信されたデータ処理要求を受信するステップであって、データ処理要求は、所定のフィールドフォーマットに従って、処理待ちデータの記述情報及び決定されたコントラクト識別情報に基づいて構築され、コントラクト識別情報に対応する目標スマートコントラクトは、処理待ちデータに対して実行すべき処理ロジックを含む、ステップと、フィールドフォーマットに従ってデータ処理要求を解析して、コントラクト識別情報、処理待ちデータの記述情報、及び対象機器の対象識別情報を取得するステップと、を実行するように構成される。

いくつかの実施例では、コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、目標スマートコントラクトにおける操作タイプ情報に対応する処理方式に従って、処理待ちデータを処理する際に、処理ユニット６０２は、対象識別情報に基づいて、対象機器が身元認証に合格したと決定する場合、コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、目標スマートコントラクト、対象識別情報、及び操作タイプ情報に基づいて、対象機器が操作タイプ情報に対応する操作を開始する権限を有すると決定した場合、処理待ちデータを取得し、目標スマートコントラクトにおける操作タイプ情報に対応する機能インターフェースを決定し、機能インターフェースに対応するアルゴリズム内容を呼び出して、処理待ちデータを処理するように構成される。

いくつかの実施例では、データ処理結果を対象機器にフィードバックする際に、処理ユニット６０２は、データ処理要求に基づいてデータ処理結果を記憶すると決定した場合、取得したデータ処理結果に対して対応するデータ識別情報を生成し、データ処理結果を対象機器にフィードバックし、及びブロックチェーンコンセンサスの原則に従って、データ識別情報及び対応するデータ処理結果を、ブロックチェーンシステム内の各ノード機器に記憶するステップと、データ処理要求に基づいてデータ処理結果を記憶しないと決定した場合、取得したデータ処理結果を対象機器に直接フィードバックするように構成される。

いくつかの実施例では、処理待ちデータを取得する際に、処理ユニット６０２は、次の動作、即ち、記述情報がブロックチェーンに記憶されているデータ内容の決定を指示するために使用される場合、記述情報に基づいてブロックチェーンから検索して得られたデータ内容を、取得した処理待ちデータとして決定するステップ、記述情報が処理待ちデータの内容を記述するために使用される場合、記述情報に基づいて決定されるデータ内容を、取得した処理待ちデータとして決定するステップ、記述情報が処理待ちデータの記憶アドレスを記述するために使用される場合、記憶アドレスに基づいて取得したデータを、処理待ちデータとして決定するステップのうちのいずれか１つを実行するように構成される。

いくつかの実施例では、データ処理装置は、並び替えユニット６０５をさらに備え、並び替えユニット６０５は、目標データ処理機能に対する機能調整処理要求を受信し、機能調整処理要求に含まれる記憶待ちスマートコントラクトを取得するステップであって、記憶待ちスマートコントラクトは、調整後の処理ロジックを含む、ステップと、目標データ処理機能と他のデータ処理要求との依存関係に基づいて、受信した各データ処理要求を並び替え、並び替え結果に基づいて各データ処理要求を処理するステップと、を実行するように構成される。

本願の例示的な実施形態のデータ処理方法及び装置を説明したが、次に、本願の別の例示的な実施形態による電子機器を説明する。

当業者は、本願の様々な態様がシステム、方法、又はプログラム製品として実現され得ることを理解することができる。したがって、本願の様々な態様は、完全なハードウェア実施形態、完全なソフトウェア実施形態（ファームウェア、マイクロコードなどを含む）、又はハードウェアとソフトウェアの両方を組み合わせた実施形態で実現でき、ここでは、「回路」、「モジュール」又は「システム」と総称することができる。

上記の実施例と同じ技術的構想に基づいて、本願の実施例は、電子機器をさらに提供し、図７に示すように、図７は、本願の実施例を適用した電子機器のハードウェア構成を示す模式図であり、電子機器７００は、少なくともプロセッサ７０１と、メモリ７０２とを備える。ここで、メモリ７０２には、プログラムコードが記憶され、プログラムコードがプロセッサ７０１によって実行されるときに、プロセッサ７０１に、上記のいずれかのデータ処理のステップを実行させる。

いくつかの可能な実施形態では、本願によるコンピューティング装置は少なくとも、少なくとも１つのプロセッサと、少なくとも１つのメモリと、を備えることができる。ここで、メモリには、プログラムコードが記憶され、プログラムコードがプロセッサ７０１によって実行されるときに、プロセッサに、本明細書に記載された、本願の様々な実施形態によるデータ処理のステップを実行させる。例えば、プロセッサは、図３Ａに示すステップを実行することができる。

以下では、図８を参照して、本願の本実施形態によるコンピューティング装置８００を説明する。図８に示すように、コンピューティング装置８００は、汎用コンピューティング装置の形態で表される。コンピューティング装置８００の構成要素は、上記の少なくとも１つの処理ユニット８０１、上記の少なくとも１つの記憶ユニット８０２、異なるシステム構成要素（記憶ユニット８０２及び処理ユニット８０１を含む）を接続するバス８０３を含み得るが、これらに限定されない。

バス８０３は、複数のタイプのバス構造の１つ又は複数を表し、メモリバス又はメモリコントローラ、周辺バス、プロセッサ、又は複数のバス構造のいずれかを使用するローカルエリアバスを含む。

記憶ユニット８０２は、ランダムアクセスメモリ（ＲＡＭ）８０２１及び／又はキャッシュメモリ８０２２などの揮発性メモリの形態の可読媒体を含んでもよいし、読み取り専用メモリ（ＲＯＭ）８２０３を含んでもよい。

記憶ユニット８０２は、1組（少なくとも１つ）のプログラムモジュール８０２４を有するプログラム／ユーティリティ８０２５をさらに含み得、このようなプログラムモジュール８０２４は、オペレーティングシステム、１つ又は複数のアプリケーション、他のプログラムモジュール、及びプログラムデータを含むが、これらに限定されず、これらの例のそれぞれ又はいくつかの組み合わせには、ネットワーク環境の実現が含まれる場合がある。

コンピューティング装置８００はまた、１つ又は複数の外部機器８０４（例えば、キーボード、ポインティングデバイスなど）と通信でき、対象とコンピューティング装置８００とのインタラクションを可能にする１つ又は複数の機器と通信でき、及び／又はコンピューティング装置８００と１つ又は複数の他のコンピューティング装置との通信を可能にする任意の機器（例えば、ルータ、モデムなど）と通信することができる。このような通信は、入力／出力（Ｉ／Ｏ）インターフェース８０５を介して行うことができる。また、コンピューティング装置８００はさらに、ネットワークアダプタ８０６を介して、１つ又は複数のネットワーク（ローカルエリアネットワーク（ＬＡＮ）、ワイドエリアネットワーク（ＷＡＮ）、及び／又はインターネットなどのパブリックネットワーク）と通信することができる。図に示すように、ネットワークアダプタ８０６は、バス８０３を介してコンピューティング装置８００の他のモジュールと通信する。理解すべきこととして、図示されていないが、コンピューティング装置８００と組み合わせて、他のハードウェア及び／又はソフトウェアモジュールを使用することができ、これには、マイクロコード、デバイスドライバ、冗長プロセッサ、外部ディスクドライブアレイ、ＲＡＩＤシステム、テープドライブ、及びデータバックアップストレージシステムが含まれるが、これらに限定されない。

上記の実施例と同じ技術的構想に基づいて、本願によって提供されるデータ処理の各態様は、プログラムコードを含むプログラム製品の形態で実現され得、前記プログラム製品が電子機器で実行されるときに、プログラムコードは電子機器に、本明細書に記載された、本願の様々な実施形態によるデータ処理のステップを実行させ、例えば、電子機器は、図３Ａに示すステップを実行することができる。

プログラム製品は、１つ又は複数の可読媒体の任意の組み合わせを採用することができる。可読媒体は、可読信号媒体又は可読記憶媒体であり得る。可読記憶媒体は、例えば、電気、磁気、光、電磁、赤外線、又は半導体のシステム、装置又はデバイス、又は上記のいずれかの組み合わせであり得るが、これらに限定されない。可読記憶媒体（非網羅的リスト）は、１つ又は複数のリード線で電気的に接続されたもの、ポータブルディスク、ハードディスク、ランダムアクセスメモリ（ＲＡＭ）、読み取り専用メモリ（ＲＯＭ）、消去可能プログラム可能読み取り専用メモリ（ＥＰＲＯＭ又はフラッシュメモリ）、光ファイバ、ポータブルコンパクトディスク読み取り専用メモリ（ＣＤ－ＲＯＭ）、光記憶デバイス、磁気記憶デバイス、又は上記の任意の適切な組み合わせを含む。

本願の好ましい実施例について説明したが、当業者にとって、基本的な創造的概念を理解すれば、これらの実施例に更なる変更や修正を加えることができる。したがって、添付の特許請求の範囲は、好ましい実施例及び本願の範囲内にあるすべての変更及び修正を含むものと解釈されることを意図している。

明らかに、当業者は、本願の精神及び範囲から逸脱することなく、本願に様々な変更及び変形を加えることができる。したがって、本願のこれらの修正及び変形が本願の特許請求の範囲及びそれに相当する技術の範囲に含まれる場合には、本願もこれらの修正及び変形を含むことを意図する。

Claims (13)

1. ブロックチェーンシステム内のノード機器が実行する、データ処理方法であって、
   対象機器から送信されたデータ処理要求を受信し、前記データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、前記処理待ちデータに対する操作タイプ情報、及び前記対象機器の対象識別情報を取得するステップであって、１つのコントラクト識別情報は、１つのスマートコントラクトを識別するために使用され、前記１つのスマートコントラクトには、少なくとも１つのデータ処理機能の処理ロジックが保存されている、ステップと、
   前記コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、前記目標スマートコントラクトにおける前記操作タイプ情報に対応する処理方式に従って、前記処理待ちデータを処理して、データ処理結果を得るステップと、
   前記データ処理結果を前記対象機器にフィードバックするステップと、を含み、
   前記データ処理方法は、
   目標データ処理機能に対する機能調整処理要求を受信し、前記機能調整処理要求に含まれる記憶待ちスマートコントラクトを取得するステップであって、前記記憶待ちスマートコントラクトは、調整後の処理ロジックを含む、ステップと、
   前記目標データ処理機能と他のデータ処理要求との依存関係に基づいて、受信した各データ処理要求を並び替え、並び替え結果に基づいて各データ処理要求を処理するステップと、をさらに含む、
   データ処理方法。
2. 各スマートコントラクトは、機能インターフェース層、アルゴリズム層、及び記憶層という３層の論理構造を含み、前記機能インターフェース層は、実現可能なデータ処理機能とデータ処理が依存するパラメータとを限定するために使用され、前記アルゴリズム層は、データ処理機能を実現するアルゴリズムの内容を限定するために使用され、前記記憶層は、データ処理結果の記憶形式を限定するために使用される、
   請求項１に記載のデータ処理方法。
3. 前記ノード機器がトラステッドコンピューティングを行うように構成され、前記データ処理要求が暗号化データに対してトラステッド処理を行うように要求するために使用される場合、前記コントラクト識別情報は、ブロックチェーン内の、暗号化して記憶されたトラステッドスマートコントラクトを識別するために使用され、前記記述情報は、暗号化して記憶された目標データを記述するために使用され、前記操作タイプ情報は、要求されたトラステッドコンピューティングタイプ情報を表し、
   前記コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、前記目標スマートコントラクトにおける前記操作タイプ情報に対応する処理方式に従って、前記処理待ちデータを処理するステップは、
   構築されたトラステッドコンピューティング環境で、暗号化して記憶されたトラステッドスマートコントラクトを復号化して、トラステッドスマートコントラクトを取得するステップと、
   前記対象機器が前記トラステッドコンピューティングタイプ情報に対応する操作を要求する権限を有すると決定した場合、暗号化して記憶された目標データを復号化して、目標データを取得するステップと、
   前記トラステッドスマートコントラクトにおいて拘束されるトラステッドコンピューティングロジックに従って、前記目標データを処理するステップと、を含む、
   請求項１に記載のデータ処理方法。
4. 前記ノード機器がトラステッドコンピューティングモードでデータ処理を行うように構成される場合、前記データ処理方法は、
   対象機器が暗号化データに対してトリガしたトラステッド処理要求を受信し、前記トラステッド処理要求に含まれる暗号化データ、暗号化スマートコントラクト、前記暗号化データに対するトラステッドコンピューティングタイプ情報、及び前記対象機器の対象識別情報を取得するステップと、
   構築されたトラステッドコンピューティング環境で、前記暗号化スマートコントラクトに基づいて復号化して、対応する目標スマートコントラクトを取得するステップと、
   前記対象機器が前記トラステッドコンピューティングタイプ情報に対応する操作を要求する権限を有すると決定した場合、前記暗号化データに基づいて復号化して、目標データを取得するステップと、
   前記目標スマートコントラクトにおいて拘束されるトラステッドコンピューティングロジックを採用して、前記目標データを処理して、トラステッドコンピューティング結果を得るステップと、
   前記トラステッドコンピューティング結果をブロックチェーンに記憶し、前記トラステッドコンピューティング結果に対応するキーワード情報を前記対象機器にフィードバックするステップと、をさらに含む、
   請求項１に記載のデータ処理方法。
5. 前記対象機器から送信されたデータ処理要求を受信する前に、前記データ処理方法は、
   ブロックチェーンシステムにおけるノード配置方式に従って、前記ノード機器を前記ブロックチェーンシステム内のノードとして構成し、前記ノード機器に異なるデータ処理機能を実現するためのスマートコントラクトを記憶するステップを含む、
   請求項１に記載のデータ処理方法。
6. 前記対象機器から送信されたデータ処理要求を受信し、前記データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、及び前記対象機器の対象識別情報を取得するステップは、
   対象機器から送信されたデータ処理要求を受信するステップであって、前記データ処理要求は、前記対象機器によって、所定のフィールドフォーマットに従って、処理待ちデータの記述情報及び決定されたコントラクト識別情報に基づいて構築され、前記コントラクト識別情報に対応する目標スマートコントラクトは、前記処理待ちデータに対して行う必要のある処理ロジックを含む、ステップと、
   前記フィールドフォーマットに従って前記データ処理要求を解析して、前記コントラクト識別情報、処理待ちデータの記述情報、及び前記対象機器の対象識別情報を取得するステップと、を含む、
   請求項１に記載のデータ処理方法。
7. 前記コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、前記目標スマートコントラクトにおける前記操作タイプ情報に対応する処理方式に従って、前記処理待ちデータを処理するステップは、
   対象識別情報に基づいて、前記対象機器が身元認証に合格したと決定する場合、前記コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索するステップと、
   前記目標スマートコントラクト、前記対象識別情報、及び前記操作タイプ情報に基づいて、前記対象機器が前記操作タイプ情報に対応する操作を開始する権限を有すると決定した場合、前記処理待ちデータを取得するステップと、
   前記目標スマートコントラクトにおける前記操作タイプ情報に対応する機能インターフェースを決定し、前記機能インターフェースに対応するアルゴリズム内容を呼び出して、前記処理待ちデータを処理するステップと、を含む、
   請求項１に記載のデータ処理方法。
8. 前記データ処理結果を前記対象機器にフィードバックするステップは、
   前記データ処理要求に基づいてデータ処理結果を記憶すると決定した場合、取得したデータ処理結果に対して対応するデータ識別情報を生成し、前記データ処理結果を前記対象機器にフィードバックし、及びブロックチェーンコンセンサスの原則に従って、前記データ識別情報及び対応するデータ処理結果を、前記ブロックチェーンシステム内の各ノード機器に記憶するステップと、
   前記データ処理要求に基づいてデータ処理結果を記憶しないと決定した場合、取得したデータ処理結果を前記対象機器に直接フィードバックするステップと、を含む、
   請求項７に記載のデータ処理方法。
9. 前記処理待ちデータを取得するステップは、
   前記記述情報がブロックチェーンに記憶されているデータ内容の決定を指示するために使用される場合、前記記述情報に基づいて前記ブロックチェーンから検索して得られたデータ内容を、取得した処理待ちデータとして決定するステップ、
   前記記述情報が処理待ちデータの内容を記述するために使用される場合、前記記述情報に基づいて決定されるデータ内容を、取得した処理待ちデータとして決定するステップ、
   前記記述情報が処理待ちデータの記憶アドレスを記述するために使用される場合、前記記憶アドレスに基づいて取得したデータを、処理待ちデータとして決定するステップのうちのいずれか１つを含む、
   請求項７に記載のデータ処理方法。
10. データ処理装置であって、
    受信ユニットと、処理ユニットと、フィードバックユニットと、を備え、
    前記受信ユニットは、対象機器から送信されたデータ処理要求を受信し、前記データ処理要求に含まれるコントラクト識別情報、処理待ちデータの記述情報、前記処理待ちデータに対する操作タイプ情報、及び前記対象機器の対象識別情報を取得するように構成され、１つのコントラクト識別情報は、１つのスマートコントラクトを識別するために使用され、前記１つのスマートコントラクトには、少なくとも１つのデータ処理機能の処理ロジックが保存されており、
    前記処理ユニットは、前記コントラクト識別情報に基づいて、記憶されたブロックチェーン内で、対応する目標スマートコントラクトを検索し、前記目標スマートコントラクトにおける前記操作タイプ情報に対応する処理方式に従って、前記処理待ちデータを処理して、データ処理結果を得るように構成され、
    前記フィードバックユニットは、前記データ処理結果を前記対象機器にフィードバックするように構成され、
    前記データ処理装置は、並び替えユニットをさらに備え、
    前記並び替えユニットは、
    目標データ処理機能に対する機能調整処理要求を受信し、前記機能調整処理要求に含まれる記憶待ちスマートコントラクトを取得することであって、前記記憶待ちスマートコントラクトは、調整後の処理ロジックを含む、こと、及び
    前記目標データ処理機能と他のデータ処理要求との依存関係に基づいて、受信した各データ処理要求を並び替え、並び替え結果に基づいて各データ処理要求を処理すること
    を行うように構成される、
    データ処理装置。
11. 各スマートコントラクトは、機能インターフェース層、アルゴリズム層、及び記憶層という３層の論理構造を含み、前記機能インターフェース層は、実現可能なデータ処理機能とデータ処理が依存するパラメータとを限定するために使用され、前記アルゴリズム層は、データ処理機能を実現するアルゴリズムの内容を限定するために使用され、前記記憶層は、データ処理結果の記憶形式を限定するために使用される、
    請求項１０に記載のデータ処理装置。
12. メモリと、プロセッサと、メモリに記憶され、プロセッサで実行可能なコンピュータプログラムと、を備え、前記プロセッサは、前記コンピュータプログラムを実行するときに、請求項１～９のいずれか一項に記載のデータ処理方法を実現する、電子機器。
13. プロセッサによって実行されるときに、プロセッサに、請求項１～９のいずれか一項に記載のデータ処理方法を実行させる、コンピュータプログラム。