Informatica-Powercenter基础开发实例

1、 基础 Informatica-Powercenter 开发实例 Infa 开发实例 1 实例：客户维表抽取( dim_customer ) 1.1 数据库配置信息 1.1.1 数据源 数据库 类型 oracle 服务器 IP 12 访问 IP 访问用户 系统性 质 xxx 系统 数据库 数据库名 称( SID) 用户名 密码 Oracle d ev Abc Abc 1.1.2 目标库 数据库 类型 oracle 服务器 IP 13 访问 IP 访问用户 系统性 数据仓库 第2页 质 数据库 数据库名 称（ SID） 用户名 密码 Oracle d ev DW

2、DW 1.2 详细设计 1.2.1 基础信息 目标位置： 数据仓库 实现目标： 抽取客户维表数据进入数据仓库供 BIEE 平台展现 功能要求： 目标表名： dim customer 来源表： Hz Parties 、 hz cust accounts 数据筛选条件： 数据更新频率： 每月 1.2.2 口径说明 字段名 字段类型 字段描述 数据源 字段 转换规则 备注 row id number 序号 market_cod e varchar2(50 ) 市场编码 market_nam e varchar2(10 0) 市场名称 customer_c ode varchar2(50 ) 客户编码

3、 hz_cust_accou nts account_n umber customer_n ame varchar2(20 0) 客户名称 Hz_Parties party_nam e 取数规则： select rownum , , ,hca.account_number,ap.party_name from Hz_Parties ap, hz_cust_accounts hca where ap.party id = hca.party id 第3页 ETL说明： Mapping ：M_DIM_CUSTOMER_Inc Workflow ： WF_DIM_CUSTOMER_Inc 更新方式：

4、 全量抽取 1.3 抽取步骤 1.3.1 定义源 1. 打开 Designer ，选择“源 - 从数据库导入”，导入源表结构 第4页 2. 选择“源-从数据库导入”后出现如下提示框， 若未配置源数据库 的 odbc，则需要先配置，可点击如下图的“”进行配置 第5页 3. 在弹出的 ODBC中，选择系统 DSN，添加按钮，选择想为其安装数 据源的驱动程序 第6页 4. 这里我们选择 oracle in oraclient10g_home1 ，弹出如下框，进 行配置， tns service name 为本机配置的 tns 连接，这里不再详述 5. 配置完我们可以点击测试，看是否能连通数据库 第7

5、页 6. 配置完 odbc，我们选择相应的 odbc 连接，输入用户名密码连接 erp 数据库，也可以在搜索栏填入指定的表，然后选择导入 第8页 第9页 7. 用同样的方式，我们将 Hz_Parties 表导入 designer 第10页 1.3.2 定义目标 1. 导入目标表的方式与导入源的方式基本一致，首先选择“目标 - 从数据库导入” 第11页 2. 选择我们配置好的 odbc，输入目标库的用户名，密码 第12页 1.3.3 创建映射 1.选择“映射 -创建”，输入映射的名称，映射命名建议以“ M_目标 表名_Inc ”方式来创建 第13页 2. 创建完映射，将刚才导入的两张源表拖入映射

6、工作区中 3. 将我们需要的字段拖入 join 组件中，并 join 组件设置两张表的关 联条件 第14页 第15页 第16页 4. 生成的 sql 或者开发人员修改了 sql 后，可以点击 “验证”，看 sql 的语法是否正确 5. 将序列号组件和目标表拖入到工作区中，并将我们通过 join 组件 关联后需要的字段与目标表关联， 序列号组件中的序列也与目标表中 的 rowid 字段关联，与目标表关联后，整个映射工作也就完成了 第17页 1.3.4 定义任务 1.打开 workflow 工具，选择“工作流 -创建”，输入工作流名称 ,工 作流命名建议以“ WF_目标表名 _Inc ”的方式 第

7、18页 2. 点击确定后，工作流创建成功，如下图所示 第19页 1.3.5 创建会话任务 1. 点击工具栏上的“ session ”组件按钮进行创建会话任务 第20页 3. 点击工具栏的“链接”组件，将“启动”与会话任务进行连接 4.点击“连接 -关系”进行数据库连接的配置 第21页 5. 点击“新建”，选择 oracle 然后选择确定 第22页 6. 在弹出的如下框中进行配置，连接字符串中的 oracle_crp 为服务 器上对应的 tns 连接串 第23页 7. 双击会话任务，在映射选项中进行数据源和目标的配置 第24页 8. 在连接类型中选择我们配置好的数据源， 源和目标的数据源都要一

8、一配置，如下图 第25页 第26页 9. 目标表配置中， target load type 属性中我们一般选择 normal 选 项， bulk 有时候会报错，对于维表的抽取，我们一般采用全量的方 式抽取，所以勾选 truncate target table 属性 第27页 1.3.6 监控工作流 1. 工作流及会话任务创建完成后， 在工作流空白工作区右键 -启动工 作流 2. 启动 workflow monitor ，可以监控工作流的执行情况 第28页 2 实例：收入分析事实表抽取( ft_income_structure ) 2.1 数据库配置信息 2.1.1 数据源 数据库 类型 ora

9、cle 服务器 IP 06 访问 IP 访问用户 系统性 质 ERP系统 数据库 数据库名 称( SID) 用户名 密码 Oracle d ev apps apps 2.1.2 目标库 数据库 类型 oracle 服务器 IP 07 访问 IP 访问用户 系统性 质 ODS中间库 第29页 数据库 数据库名 称（ SID） 用户名 密码 Oracle h yperion INFO OD S INFO ODS 2.2 详细设计 2.2.1 基础信息 目标位置： ODS中间库 实现目标： 抽取收入分析数据进入 ODS中间库 功能要求： 目标表名： MT INCOME

10、 STRUCTURE 来源表： Ra_Customer_Trx_All Ra_Customer_Trx_Lines_All RA_CUST_TRX_LINE_GL_DIST_ALL Hz_Parties HZ_CUST_ACCOUNTS gl_code_combinations FND_FLEX_VALUE_SETS FND_FLEX_VALUES_VL mtl system items b 数据筛选条件： 数据更新频率： 每月 2.2.2 口径说明 字段名 字段类型 字段描述 数据源 字段 转换规则 备注 MONT _ID HNUMBE R 月份 RA_CUS T_TRX_ LINE G g

11、l_d ate to_c har( gl_d ate, 第30页 L_DIST _ALL YYY YMM ) ORG_I D NUMBE R 组织 gl_cod e_comb inatio ns segm ent1 PROD CT_ID UNUMBE R 产品 mtl_sy stem_i tems b segm ent1 ACCO NT_ID UNUMBE R 科目 gl_cod e_comb inatio ns segm ent3 CUSTO MER_I D NUMBE R 客户 HZ_CUS T_ACCO UNTS acco unt_ numb er INDEX VALU NUMBE R

12、指标 值 RA_CUS T TRX amou nt 第31页 E LINE_G L_DIST ALL 取数规则： select rac.account_number customer_id, to_char(gd.gl_date, YYYYMM ) month_id, gcc.segment1 org_id, gcc.segment3 account_id, msi.segment1 product, sum (gd.amount) data_value from Ra_Customer_Trx_All ct, Ra_Customer_Trx_Lines_All ctl, RA_CUST_TR

13、X_LINE_GL_DIST_ALL gd, Hz_Parties hp, HZ_CUST_ACCOUNTSRAC, gl_code_combinations gcc, FND_FLEX_VALUE_SETSFFS, FND_FLEX_VALUES_VL FFV, mtl_system_items_b msi where ct.customer_trx_id = ctl.customer_trx_id and gd.customer_trx_id = ct.customer_trx_id and gd.customer_trx_line_id = ctl.customer_trx_line_i

14、d and hp.party_id = rac.party_id and ct.bill_to_customer_id = rac.cust_account_id and gd.account_class = REV and gd.amount is not null and gd.amount 0 and gcc.code_combination_id = gd.code_combination_id AND gcc.chart_of_accounts_id = 50368 and FFS.FLEX_VALUE_SET_ID = 1014869 and FFV.FLEX_VALUE_SET_

15、ID = FFS.FLEX_VALUE_SET_ID and FFV.Flex_Value = gcc.segment3 and substr(ffv.FLEX_VALUE, 1, 1) = 6 and anization_id =81 and msi.inventory_item_id = ctl.inventory_item_id group by rac.account_number, to_char(gd.gl_date, YYYYMM ), gcc.segment1, gcc.segment3, msi.segment1; 第32页 ETL说明： Mapping ：M_ MT_INCOME_STRUCTURE_Inc Workflow ： WF_ MT_INCOME_STRUCTURE_Inc 更新方式： 第一次全量抽取，之后每月增量抽取 2.3 抽取步骤 2.3.1 定义源 1. 由于抽取任务涉及源表过多， 关联关系复杂， 并且已经