[OCI]Oracle Functions - Node.JSによるATPへの接続 (2019/08/02)

Oracle Functions - Node.JSによるATPへの接続 (2019/08/02)

https://blogs.oracle.com/developers/oracle-functions-connecting-to-atp-with-nodejs
投稿者：Todd Sharp

前回の記事では、Javaベースのサーバーレスファンクションを使ってATPに接続する方法を見ました。
それは素晴らしい結果でしたが、Node.JSベースのファンクションを使って同じタスクを達成する方法をお見せしたいと思いました。
この記事では、データを保存する方法に少しひねりを加えて、ちょうどそれを行います。

開始するには、Fn CLIを使って新しいFnアプリケーションを作成します。今回はcreate appコールで直接設定値を渡します。

$ fn create app --annotation oracle.com/oci/subnetIds='["ocid1.subnet.oc1.phx..."]' --config DB_PASSWORD='[DB PASS]' --config DB_USER='[DB USER]]' --config CONNECT_STRING='[CONNECT STRING FROM tnsnames.ora]' fn-atp-node-json


注意: 機密情報を含む設定変数は、常に暗号化する必要があります。その方法については、OCI でのKey Managementの使い方のガイドを参照してください。

さて、最初のファンクションを作りますが、前回のようにinit-imageを使うのではなく、ノードランタイムを使って、自分たちで変更してみましょう。

fn init --runtime node fn-atp-node-json-insert


生成されたfunc.yamlファイルを開き、runtimeの値をdockerに変更します。
下図のようにformat、memory、timeout、idle_timeoutの値を追加します。

schema_version: 20180708
name: fn-atp-node-json-insert
version: 0.0.91
runtime: docker
format: http-stream
memory: 256
timeout: 120
idle_timeout: 1800


ファンクションのルートにDockerfileを作成します。
先ほどと同じようにウォレットが必要になります（ダウンロードしてファンクションのルートに置いてください）。
しかし、今回はNodeが適切な接続を行うためにOracle Instant Clientも必要になります。
そして、その依存関係を取得してDockerfileにインストールします。Dockerfile全体は以下のようになります。

FROM oraclelinux:7-slim

RUN yum -y install oracle-release-el7 oracle-nodejs-release-el7 &&
\ yum-config-manager --disable ol7_developer_EPEL &&
\ yum -y install oracle-instantclient19.3-basiclite nodejs &&
\ rm -rf /var/cache/yum &&
\ groupadd --gid 1000 --system fn &&
\ useradd --uid 1000 --system --gid fn fn

COPY wallet/* /usr/lib/oracle/19.3/client64/lib/network/admin/

WORKDIR /function
ADD package.json package-lock.json func.js func.yaml /function/
RUN npm install
ENTRYPOINT ["node", "func.js"]


このDockerfileでは、ベースイメージとしてOracle Linuxを使用し、
インスタントクライアントの依存関係を手動でインストールするのではなく、Oracle yumリポジトリを経由してインストールしています。
また、ウォレットファイルをコピーして、接続に使用できるようにしています。最後に、node func.jsをentrypointに設定します。

次に、ファンクションルートからnpm install oracledbとnpm install dateformatを実行します。
これにより、Oracle Nodeパッケージと日付書式設定ライブラリがインストールされるので、それらをクエリに使用することができます。
このデモで読み書きに使用するテーブルを作成する必要があります。今回はATPのJSONカラムサポートを利用するので、テーブルはとてもシンプルなものになります。

CREATE TABLE JSON_DEMO
(
ID NUMBER GENERATED BY DEFAULT ON NULL AS IDENTITY INCREMENT BY 1 MAXVALUE 9999999999999999999999999999 MINVALUE 1 CACHE 20 NOT NULL
, CAPTURED_AT TIMESTAMP(6)
, DATA CLOB
, CONSTRAINT JSON_DEMO_PK PRIMARY KEY ( ID )
)


では、ファンクションを見てみましょう。func.jsを開き、以下のように入力します。

const fdk = require('@fnproject/fdk');
const oracledb = require('oracledb');
oracledb.outFormat = oracledb.OBJECT;
oracledb.fetchAsString = [oracledb.CLOB];

let pool;

fdk.handle( async function(input){
if( !pool ) {
pool = await oracledb.createPool({
user: process.env.DB_USER,
password: process.env.DB_PASSWORD,
connectString: process.env.CONNECT_STRING,
});
}
const connection = await pool.getConnection();
const records = await connection.execute("select * from json_demo");
const result = records.rows.map((row) => {
return {
id: row.ID,
capturedAt: row.CAPTURED_AT,
data: JSON.parse(row.DATA),
}
});
await connection.close();
return result;
}, {});


ここでは、必要なライブラリ（FDK for NodeとOracle DBパッケージ）を取り込み、ファンクションが呼び出されたときに呼び出される単一のメソッドを作成します。
このファンクションの中で、DBへの接続を確立し、すべてのレコードをクエリしてオブジェクトの配列として返します。
デプロイして呼び出してテストすることができますが、明らかにこの時点では結果は空の配列になるので、挿入を処理するファンクションも作成しましょう。
上記のプロジェクト全体をコピーして貼り付け、func.yaml内のファンクション名を変更して挿入ファンクションを作成しますが、代わりにfunc.jsを変更して挿入を処理するようにします。

const fdk = require('@fnproject/fdk');
const oracledb = require('oracledb');
const dateFormat = require('dateformat');

oracledb.outFormat = oracledb.OBJECT;
oracledb.fetchAsString = [oracledb.CLOB];

let pool;

fdk.handle( async function(input){
if( !pool ) {
pool = await oracledb.createPool({
user: process.env.DB_USER,
password: process.env.DB_PASSWORD,
connectString: process.env.CONNECT_STRING,
});
}
const connection = await pool.getConnection();
const insert = await connection.execute("insert into json_demo (data, captured_at) values (:data, to_timestamp(:capturedAt, 'yyyy-mm-dd HH24:mi:ss'))",
{
data: JSON.stringify(input),
capturedAt: dateFormat(new Date(), 'yyyy-mm-dd HH:MM:ss')
},
{ autoCommit: true }
);
await connection.close();
return {insert: insert, complete: true};
}, {});


このファンクションをデプロイし、永続化したいデータを含む JSON オブジェクトを渡して呼び出します。JSONオブジェクトは、有効なJSONであれば何でも構いません。

echo '{"isDemo": true, "key": 5, "isAwesome": true, "isEasy": true}' | fn invoke fn-atp-node-json fn-atp-node-json-insert


この時点で読み込みファンクションを呼び出して、前の挿入の結果を見ることができます。

trsharp@MacBook-Pro-2 ~/Projects/fn/fn-atp-node-json/throwaway$ fn invoke fn-atp-node-json fn-atp-node-json-read

[{"id":66,"capturedAt":"2019-06-11T21:33:04.000Z","data":{"isDemo":true,"key":5,"isAwesome":true,"isEasy":true}}]


上記の例の代替として、ファンクションはSimple Oracle Data Access (SODA)を使用して、
他のNoSQL実装に馴染みのあるスタイルでデータを処理することもできます。SODA は定義済みのテーブルやスキーマを必要とせず、
従来の SQL の代わりにドキュメント コレクションと簡略化された API を使用して動作します（API のみを使用することに制限されるわけではありませんが、
必要に応じて従来の SQL を使用してコレクションに問い合わせを行うことはもちろん可能です）。
必要であれば、もちろん従来の SQL を使ってコレクションを照会することができます。SODA を使うファンクションの例を以下に示します。

const fdk = require('@fnproject/fdk');
const oracledb = require('oracledb');

oracledb.outFormat = oracledb.OBJECT;
oracledb.fetchAsString = [oracledb.CLOB];
oracledb.autoCommit = true;

fdk.handle( async function(input){

let connection;
const result = [];

try {
connection = await oracledb.getConnection({
user: process.env.DB_USER,
password: process.env.DB_PASSWORD,
connectString: process.env.CONNECT_STRING,
});

const soda = connection.getSodaDatabase();
const collectionName = 'soda_collection';
const collection = await soda.createCollection(collectionName);

const document = input;
await collection.insertOne(document);

const documents = await collection.find().getDocuments();

documents.forEach(function(element) {
result.push( {
id: element.key,
createdOn: element.createdOn,
lastModified: element.lastModified,
document: element.getContent(),
} );
});
}
catch(err) {
console.error(err);
}
finally {
if (connection) {
try {
await connection.close();
} catch(err) {
console.error(err);
}
}
}

return result;
}, {});


以下のようにSODAファンクションを呼び出すとします。

$ echo '{"id": 1, "temp": 58}' | fn invoke fn-atp-node-json fn-atp-node-json-soda
$ echo '{"id": 2, "temp": 60}' | fn invoke fn-atp-node-json fn-atp-node-json-soda


soda_collectionと呼ばれるテーブルに2つのレコードができます。
このテーブルはSODA APIを使用して "例題によるクエリ "の方法でクエリを行うことができます（詳細はSODA Nodeのドキュメントを参照してください）が、
次のようにSQLでクエリを行うこともできます（BLOBとして保存されているので、JSONドキュメントをvarchar2にキャストする必要があることに注意してください）。

select id, utl_raw.cast_to_varchar2(json_document) as doc
from soda_collection sc
where sc.json_document.temp < 60;

/*
ID DOC
----- -----
E05734C093684FBEBFDEC3404099F959 {"id":1,"temp":58}
*/


もう一つのオプションは、ドキュメントを従来のテーブル形式に変換して、ビューで使用したり、json_tableを使用してリレーショナルテーブルに結合したりすることです。

select id, jt.temp, jt.docId
from soda_collection sc,
json_table(json_document, '$' COLUMNS (temp number PATH '$.temp', docId varchar2(50) PATH '$.id')) as jt

/*
ID TEMP DOCID
----- ----- -----
E05734C093684FBEBFDEC3404099F959 58 1
B675F6056E374F9ABF76C6E35A280ED5 60 2
*/


次回の記事では、OCI Java SDKを使用してOracle Functionsを呼び出す方法を見ていきます。

Photo by Paul Esch-Laurent on Unsplash

コメント

コメントを投稿

このブログの人気の投稿

Oracle RACによるメンテナンスのためのドレインとアプリケーション・コンティニュイティの仕組み (2023/11/01)

イメージ
Oracle RACによるメンテナンスのためのドレインとアプリケーション・コンティニュイティの仕組み (2023/11/01) https://database-heartbeat.com/2023/11/01/draining-ac-rac/ はじめに Oracle RACは、Oracle Databaseのスケーラビリティと高可用性を提供します。1つのサーバー(RACノード)に障害が発生した場合、またはメンテナンスのためにオフラインになった場合でも、追加のノードを介してデータベースにアクセスできます。ただし、メンテナンスの開始時に、データの読取りまたは変更に関係なく、一部の作業を実行しているクライアント・セッションはどうなりますか。この作業は中断され、ドレインを実装してアプリケーション・コンティニュイティまたは透過的アプリケーション・コンティニュイティを有効にしないかぎり、エンドユーザーまたはアプリケーションによって再度実行する必要があります。 環境 2ノードのOracle RACを例に挙げて、高速アプリケーション通知(FAN)、ドレインおよびアプリケーション・コンティニュイティによってメンテナンス・イベントがエンドユーザーに透過的になる方法を理解しましょう。アプリケーションは、30個のセッションを保持するように構成された接続プールを使用しています。 通常の操作 通常の操作中は、両方のRACノードが起動し、アプリケーションを実行しています。ロード・バランシング戦略によっては、セッションの数が両方のノード間で異なるか、均等に分散される場合があります。次の図をよりよく視覚化するために、ノード2のノード1および20のセッションに10のセッションがあるとします。 セッションは、アイドル状態(接続されているが何もしていない)またはアクティブ状態(リクエストの途中)にできます。リクエストは、データの読取り(SELECT)または操作(INSERT、DELETE、UPDATE)が可能です。 ドレインによるサービスの停止 ある時点で、システムのメンテナンスが必要になります。2ノードRACがあるため、メンテナンスはローリング方式で、1つのノードを順番に(ほとんどの場合)実行できます。メンテナンスは、たとえば、オペレーティング・システム、Grid Infrastructureまたはデ
続きを読む

Oracle Cloud Infrastructure Secure Desktopsを発表: デスクトップ仮想化のためのOracleのクラウドネイティブ・サービス (2023/06/28)

イメージ
Oracle Cloud Infrastructure Secure Desktopsを発表: デスクトップ仮想化のためのOracleのクラウドネイティブ・サービス (2023/06/28) https://blogs.oracle.com/cloud-infrastructure/post/secure-desktops-cloud-native-virtualization 投稿者： Joost Pronk Van Hoogeveen Jan Hendrik Mangold | Principal Product Manager Oracleは、Oracle Cloud Infrastructure(OCI)Secure Desktopsという新しいクラウド・ネイティブ・サービスをリリースしています。このエキサイティングな開発により、顧客はOCIテナンシから簡単にすばやく仮想デスクトップ・インフラストラクチャ(VDI)をデプロイできます。 OCIの使用状況は大幅に拡大しています。組織は、OCI内でデータを安全に保つことの価値を実現しています。ゼロトラストなセキュリティ優先アーキテクチャを実装することで、OCI Compute、Storage、およびNetworkingサービスは、グローバル・アクセスのためのエンタープライズ・アプリケーションを導入するための信頼できるプラットフォームを提供します。 データ・セキュリティとVDIがどのように役立つか 業界のアナリストによると 、ラップトップは53秒ごとに盗まれています。その事実と現実を結び付けると、会社のデータは、公共の場所を経由したり、従業員の自宅に座ったりするラップトップやデスクトップへと移行します。ローカル・ディスクの暗号化、データ・アクセス権限の強制、VPNアクセスの保護によってデータを保護するためにテクノロジが使用されていますが、いずれも許容可能なセキュリティ・レベルが適用されるため、リスクは依然として高くなる可能性があります。盗難または準拠していないいくつかのマシンでは、企業データ、さらには顧客データのデータ侵害が発生する可能性があります。 VDIテクノロジは長年にわたって存在してきましたが、従業員はローカル・マシンを使用して、会社のデータ・センター内の仮想マシンで実行されているデスクトップ・アプリケー
続きを読む

新しいOracle Container Engine for Kubernetesの機能強化により、大規模なKubernetesがさらに簡単になりました (2023/03/20)

イメージ
新しいOracle Container Engine for Kubernetesの機能強化により、大規模なKubernetesがさらに簡単になりました (2023/03/20) https://blogs.oracle.com/cloud-infrastructure/post/oracle-container-engine-kubernetes-enhancements 投稿者： Mickey Boxell | Product Management Linux以降、 Kubernetes はオープンソースソフトウェアの歴史上最も急速に成長しているプロジェクトです。10年も経たないうちに、 Kubernetesは主流 になり、特に過去2年間で導入がかつてないほど大きくなりました。 Oracle Cloud Infrastructure(OCI) は、この勢いも見ています。あらゆる業界の何千ものエンタープライズ顧客が、クラウドネイティブアプリケーション開発のメリットを経験しており、その導入を迅速化し、Kubernetesの使用を拡大しています。 Oracle Container Engine for Kubernetes (OKE)で実行されている抽出、変換、ロード(ETL)ジョブ、パイプライン、ハイパフォーマンスコンピューティング(HPC)ワークロード、さらにはデータベースなどにKubernetesを使用するために、顧客はKubernetesで標準化されており、コンテナ化されたアプリケーションを実行するのみでなく拡張されています。  「私たちは、Kubernetes インフラストラクチャと OKE、GPU、HPC、およびストリーミング、OpenSearch などの最新の開発者サービスを組み合わせて使用​​して、OCI で数十億の音声 AI クエリを実行しています。私たちは、次世代のトレーニングと配信に最適なクラウドとして OCI を選択しました。 AI アプリケーション – Mercedes Benz、Toast、VIZIO、Hyundai などのグローバル ブランドに最速かつ最も正確な音声エクスペリエンスを提供するのに役立ちます.OCI を使用することで、以前のクラウドと比較してパフォーマンスが 50 ～ 60% 向上しました。 2 倍のコスト削減 – 使用量
続きを読む