使用 Oracle 创建自定义插件

1. 在命令提示符下，导航到存储DAG代码的目录。例如：

   cd dags

2. 复制以下代码示例的内容，并在本地另存为 oracle.py。

   from airflow import DAG
   from airflow.operators.python_operator import PythonOperator
   from airflow.utils.dates import days_ago
   import os
   import cx_Oracle
   
   DAG_ID = os.path.basename(__file__).replace(".py", "")
   
   def testHook(**kwargs):
       cx_Oracle.init_oracle_client()
       version = cx_Oracle.clientversion()
       print("cx_Oracle.clientversion",version)
       return version
   
   with DAG(dag_id=DAG_ID, schedule_interval=None, catchup=False, start_date=days_ago(1)) as dag:
       hook_test = PythonOperator(
           task_id="hook_test",
           python_callable=testHook,
           provide_context=True 
       )

拉取 Amazon Linux 容器镜像

1. 在命令提示符下，提取 Amazon Linux 容器镜像，然后在本地运行该容器。例如：

   docker pull amazonlinux
   docker run -it amazonlinux:latest /bin/bash

   命令提示符应该调用 bash 命令行。例如：

   bash-4.2#

2. 安装 Linux 原生异步 I/O 工具（libaio）。

   yum -y install libaio

3. 请将此窗口保持打开状态以供后续步骤使用。我们将在本地复制以下文件：lib64/libaio.so.1、lib64/libaio.so.1.0.0、lib64/libaio.so.1.0.1。

下载客户端文件夹

1. 在本地安装解压缩包。例如：

   sudo yum install unzip

2. 创建 oracle_plugin 目录。例如：

   mkdir oracle_plugin
   cd oracle_plugin

3. 使用以下 curl 命令从适用于 Linux x86-64（64 位）的 Oracle 即时客户端下载中下载 instantclient-basic-linux.x64-18.5.0.0.0dbru.zip。

   curl https://download.oracle.com/otn_software/linux/instantclient/185000/instantclient-basic-linux.x64-18.5.0.0.0dbru.zip > client.zip

4. 解压缩 client.zip 文件。例如：

   unzip *.zip

从 Docker 中提取文件

1. 在新的命令提示符下，显示并写下 Docker 容器 ID。例如：

   docker container ls

   您的命令提示符应返回所有容器及其容器IDs。例如：

   debc16fd6970

2. 在 oracle_plugin 目录中，将 lib64/libaio.so.1、lib64/libaio.so.1.0.0、lib64/libaio.so.1.0.1 文件解压缩到本地 instantclient_18_5 文件夹。例如：

   docker cp debc16fd6970:/lib64/libaio.so.1 instantclient_18_5/
   docker cp debc16fd6970:/lib64/libaio.so.1.0.0 instantclient_18_5/
   docker cp debc16fd6970:/lib64/libaio.so.1.0.1 instantclient_18_5/

• 复制以下代码示例的内容，并在本地另存为 env_var_plugin_oracle.py。

  from airflow.plugins_manager import AirflowPlugin
  import os
  
  os.environ["LD_LIBRARY_PATH"]='/usr/local/airflow/plugins/instantclient_18_5'
  os.environ["DPI_DEBUG_LEVEL"]="64"
  
  class EnvVarPlugin(AirflowPlugin):                
      name = 'env_var_plugin' 

压缩插件目录中的内容。

1. 在命令行提示符中，导航到 oracle_plugin 目录。例如：

   cd oracle_plugin

2. 将 instantclient_18_5 目录压缩到 plugins.zip 中。例如：

   zip -r ../plugins.zip ./

3. 您应该在命令提示符中看到如下内容：

   oracle_plugin$ ls
   client.zip		instantclient_18_5

4. 移除该 client.zip 文件。例如：

   rm client.zip

压缩 env_var_plugin_oracle.py 文件

1. 将 env_var_plugin_oracle.py 文件添加到 plugins.zip 文件的根目录。例如：

   zip plugins.zip env_var_plugin_oracle.py

2. plugins.zip 现在应包含以下内容：

   env_var_plugin_oracle.py
   instantclient_18_5/