碼上快樂

相關內容    簡體    繁體

微博excel數據清洗(Java版)

本文轉載自   查看原文   2017-11-08 11:38   1009    mapreduce/ hadoop/ 大數據--Hadoop系列

微博數據清洗(Java版)

原創 2013年12月10日 10:58:24

大數據公益大學提供的一份數據，義務處理一下，原始數據是Excel，含有html標簽，如下：

 

要求清洗掉html標簽，和微博內容中的url地址。

 

主要分為兩部分：

1.處理文本，清洗數據。

2.處理excel讀寫操作。

 

上代碼：

ExcelUtil類，包含Excel2003-2007的讀寫操作,Excel使用Apache POI進行操作,需要jar包如下：


 

[java]  view plain  copy
 
  1. package dat.datadeal;  
  2.   
  3. import java.io.File;  
  4. import java.io.FileInputStream;  
  5. import java.io.FileNotFoundException;  
  6. import java.io.FileOutputStream;  
  7. import java.io.IOException;  
  8. import java.io.InputStream;  
  9. import java.text.ParseException;  
  10. import java.text.SimpleDateFormat;  
  11. import java.util.ArrayList;  
  12. import java.util.Date;  
  13. import java.util.List;  
  14. import java.util.Locale;  
  15. import java.util.logging.Level;  
  16. import java.util.logging.Logger;  
  17.   
  18. import org.apache.poi.hssf.usermodel.HSSFCell;  
  19. import org.apache.poi.hssf.usermodel.HSSFCellStyle;  
  20. import org.apache.poi.hssf.usermodel.HSSFRow;  
  21. import org.apache.poi.hssf.usermodel.HSSFSheet;  
  22. import org.apache.poi.hssf.usermodel.HSSFWorkbook;  
  23. import org.apache.poi.ss.usermodel.Cell;  
  24. import org.apache.poi.ss.usermodel.DateUtil;  
  25. import org.apache.poi.ss.usermodel.Row;  
  26. import org.apache.poi.ss.usermodel.Sheet;  
  27. import org.apache.poi.ss.usermodel.Workbook;  
  28. import org.apache.poi.xssf.usermodel.XSSFWorkbook;  
  29.   
  30. /** 
  31.  *  
  32.  * @author daT dev.tao@gmail.com 
  33.  *2003,2007版excel讀寫工具 
  34.  */  
  35. public class ExcelUtil{  
  36.       
  37.     /** 
  38.      * Excel文件讀取 
  39.      * @param filePath 
  40.      * @return String[]存的是行，List存的是列。 
  41.      * 一個excel一次全部讀入內存(Excel超大需要另行處理) 
  42.      */  
  43.     public  List<String[]> readExcel(String filePath) {    
  44.         List<String[]> dataList = new ArrayList<String[]>();    
  45.         boolean isExcel2003 = true;    
  46.         if (isExcel2007(filePath)) {    
  47.             isExcel2003 = false;    
  48.         }    
  49.         File file = new File(filePath);    
  50.         InputStream is = null;    
  51.         try {    
  52.             is = new FileInputStream(file);    
  53.         } catch (FileNotFoundException ex) {    
  54.             Logger.getLogger(ExcelUtil.class.getName()).log(Level.SEVERE, null, ex);    
  55.         }    
  56.         Workbook wb = null;    
  57.         try {    
  58.             wb = isExcel2003 ? new HSSFWorkbook(is) : new XSSFWorkbook(is);    
  59.         } catch (IOException ex) {    
  60.             Logger.getLogger(ExcelUtil.class.getName()).log(Level.SEVERE, null, ex);    
  61.         }    
  62.         Sheet sheet = wb.getSheetAt(0);    
  63.         int totalRows = sheet.getPhysicalNumberOfRows();    
  64.         int totalCells = 0;    
  65.         if (totalRows >= 1 && sheet.getRow(0) != null) {    
  66.             totalCells = sheet.getRow(0).getPhysicalNumberOfCells();    
  67.         }    
  68.         for (int r = 0; r < totalRows; r++) {    
  69.             Row row = sheet.getRow(r);    
  70.             if (row == null) {    
  71.                 continue;    
  72.             }    
  73.             String[] rowList = new String[totalCells];    
  74.             for (int c = 0; c < totalCells; c++) {    
  75.                 Cell cell = row.getCell(c);    
  76.                 String cellValue = "";    
  77.                 if (cell == null) {    
  78.                     rowList[c] = (cellValue);    
  79.                     continue;    
  80.                 }    
  81.                 cellValue = ConvertCellStr(cell, cellValue);    
  82.                 rowList[c] = (cellValue);    
  83.             }    
  84.             dataList.add(rowList);    
  85.         }    
  86.         return dataList;    
  87.     }    
  88.       
  89.       
  90.     private String ConvertCellStr(Cell cell, String cellStr) {    
  91.         switch (cell.getCellType()) {    
  92.             case Cell.CELL_TYPE_STRING:    
  93.                 // 讀取String    
  94.                 cellStr = cell.getStringCellValue().toString();    
  95.                 break;    
  96.             case Cell.CELL_TYPE_BOOLEAN:    
  97.                 // 得到Boolean對象的方法    
  98.                 cellStr = String.valueOf(cell.getBooleanCellValue());    
  99.                 break;    
  100.             case Cell.CELL_TYPE_NUMERIC:    
  101.                 // 先看是否是日期格式    
  102.                 if (DateUtil.isCellDateFormatted(cell)) {    
  103.                     // 讀取日期格式    
  104.                     cellStr = formatTime(cell.getDateCellValue().toString());    
  105.                 } else {    
  106.                     // 讀取數字    
  107.                     cellStr = String.valueOf(cell.getNumericCellValue());    
  108.                 }    
  109.                 break;    
  110.             case Cell.CELL_TYPE_FORMULA:    
  111.                 // 讀取公式    
  112.                 cellStr = cell.getCellFormula().toString();    
  113.                 break;    
  114.         }    
  115.         return cellStr;    
  116.     }    
  117.     
  118.   
  119.   
  120.     private boolean isExcel2007(String fileName) {    
  121.             return fileName.matches("^.+\\.(?i)(xlsx)$");    
  122.      }   
  123.        
  124.     private String formatTime(String s) {    
  125.         SimpleDateFormat sf = new SimpleDateFormat("EEE MMM dd hh:mm:ss z yyyy", Locale.ENGLISH);    
  126.         Date date = null;    
  127.         try {    
  128.             date = sf.parse(s);    
  129.         } catch (ParseException ex) {    
  130.             Logger.getLogger(ExcelUtil.class.getName()).log(Level.SEVERE, null, ex);    
  131.         }    
  132.         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");    
  133.         String result = sdf.format(date);    
  134.         return result;    
  135.     }    
  136.        
  137.       
  138.     /** 
  139.      * Excel寫操作,簡單起見還是采用內存數據一次寫入 
  140.      * @param filePath 輸出文件路徑名 
  141.      * @param dataList 輸出文件內容，List<String>行  List列 
  142.      * @throws IOException 
  143.      */  
  144.     public  void writeExcel(String filePath,List<List<String>> dataList) throws IOException{  
  145.             HSSFWorkbook wb = new HSSFWorkbook();    
  146.             HSSFSheet sheet = wb.createSheet("sheet");// 添加sheet    
  147.             // 表格樣式    
  148.             HSSFCellStyle style = wb.createCellStyle();    
  149.             style.setAlignment(HSSFCellStyle.ALIGN_CENTER);// 指定單元格居中對齊    
  150.             // // 邊框    
  151.             // style.setBorderBottom(HSSFCellStyle.BORDER_MEDIUM);    
  152.             // style.setBorderTop(HSSFCellStyle.BORDER_MEDIUM);    
  153.             // style.setBorderLeft(HSSFCellStyle.BORDER_MEDIUM);    
  154.             // style.setBorderRight(HSSFCellStyle.BORDER_MEDIUM);    
  155.             // //設置字體    
  156.             // HSSFFont f = wb.createFont();    
  157.             // f.setFontHeightInPoints((short)10);    
  158.             // f.setBoldweight(HSSFFont.BOLDWEIGHT_NORMAL);    
  159.             // style.setFont(f);    
  160.             // //設置列寬    
  161.             // sheet.setColumnWidth((short)0, (short)9600);    
  162.             // sheet.setColumnWidth((short)1, (short)4000);    
  163.             // sheet.setColumnWidth((short)2, (short)8000);    
  164.             // sheet.setColumnWidth((short)3, (short)8000);    
  165.         
  166.             // 在索引0的位置創建第一行    
  167.         
  168.             for (int i = 0; i < dataList.size(); i++) {    
  169.                 HSSFRow row = sheet.createRow(i);    
  170.                 List<String> list = dataList.get(i);    
  171.                 for (int j = 0; j < list.size(); j++) {    
  172.                     HSSFCell cell = row.createCell(j);    
  173.                     cell.setCellValue(list.get(j));    
  174.                     cell.setCellStyle(style);    
  175.                 }    
  176.             }    
  177.             // 導出文件    
  178.             FileOutputStream fout = new FileOutputStream(filePath);    
  179.             wb.write(fout);    
  180.             fout.close();    
  181.     }  
  182.       
  183. }  

DataClean類，包含對html標簽，信息中url的的清洗。

 

 

[java]  view plain  copy
 
  1. package dat.datadeal;  
  2.   
  3. import java.io.IOException;  
  4. import java.util.ArrayList;  
  5. import java.util.List;  
  6. import java.util.regex.Matcher;  
  7. import java.util.regex.Pattern;  
  8.   
  9. /** 
  10.  *  
  11.  * @author daT dev.tao@gmail.com 
  12.  * 
  13.  */  
  14. public class DataClean {  
  15.       
  16.     /** 
  17.      * 清洗html標簽 
  18.      * @param inputString 
  19.      * @return 
  20.      */  
  21.     public static String delHtml(String inputString) {  
  22.         String htmlStr = inputString; // 含html標簽的字符串  
  23.         String textStr = "";  
  24.         java.util.regex.Pattern p_script;  
  25.         java.util.regex.Matcher m_script;  
  26.         java.util.regex.Pattern p_html;  
  27.         java.util.regex.Matcher m_html;  
  28.         try {  
  29.             String regEx_html = "<[^>]+>"; // 定義HTML標簽的正則表達式  
  30.             String regEx_script = "<[/s]*?script[^>]*?>[/s/S]*?<[/s]*?//[/s]*?script[/s]*?>"; // 定義script的正則表達式{或<script[^>]*?>[/s/S]*?<//script>  
  31.             p_script = Pattern.compile(regEx_script, Pattern.CASE_INSENSITIVE);  
  32.             m_script = p_script.matcher(htmlStr);  
  33.             htmlStr = m_script.replaceAll(""); // 過濾script標簽  
  34.             p_html = Pattern.compile(regEx_html, Pattern.CASE_INSENSITIVE);  
  35.             m_html = p_html.matcher(htmlStr);  
  36.             htmlStr = m_html.replaceAll(""); // 過濾html標簽  
  37.             textStr = htmlStr;  
  38.         } catch (Exception e) {  
  39.             System.err.println("Html2Text: " + e.getMessage());  
  40.         }  
  41.         return textStr;// 返回文本字符串  
  42.     }  
  43.       
  44.     /** 
  45.      * 處理掉信息中的url地址 
  46.      */  
  47.     public static String dealWithUrl(String str){  
  48.         String regEx = "[http|https]+[://]+[0-9A-Za-z:/[-]_#[?][=][.][&]]*";  
  49.         Pattern p = Pattern.compile(regEx);     
  50.         Matcher m = p.matcher(str);  
  51.         return m.replaceAll("");  
  52.     }  
  53.       
  54.       
  55.     public static void main(String[] args) throws IOException{  
  56.         ExcelUtil excelUtil = new ExcelUtil();  
  57.         List<List<String>> writeList = new ArrayList<List<String>>();  
  58.         List<String[]> readList =excelUtil.readExcel("/home/dat/javatest/微博數據_.xlsx");  
  59.         for(String[] lineArray:readList){  
  60.             List<String> strList = new ArrayList<String>();  
  61.             for(String str:lineArray){  
  62.                 String strTmp = DataClean.dealWithUrl(DataClean.delHtml(str));  
  63.                 strList.add(strTmp);  
  64.                 //System.out.println(strTmp);  
  65.             }  
  66.             writeList.add(strList);  
  67.         }  
  68.           
  69.         excelUtil.writeExcel("/home/dat/javatest/weibo.xlsx",writeList);    
  70.         System.out.println("job has finished...........");  
  71.     }  
  72. }  

 

清洗后數據：

 


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 數據清洗 數據清洗 HIVE數據清洗 SQL數據清洗 數據清洗 MapReduce數據清洗 [數據清洗]- Pandas 清洗“臟”數據（三） 數據清洗與規約方法 python之NLP數據清洗 數據清洗基本概念
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM