spark_api.py 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. """
  2. 用户输入:
  3. model数组,每个元素代表一个页面
  4. pdf在s3的路径
  5. 截图保存的s3位置
  6. 然后:
  7. 1)根据s3路径,调用spark集群的api,拿到ak,sk,endpoint,构造出s3PDFReader
  8. 2)根据用户输入的s3地址,调用spark集群的api,拿到ak,sk,endpoint,构造出s3ImageWriter
  9. 其余部分至于构造s3cli, 获取ak,sk都在code-clean里写代码完成。不要反向依赖!!!
  10. """
  11. from magic_pdf.io import AbsReaderWriter
  12. from magic_pdf.pdf_parse_by_ocr import parse_pdf_by_ocr
  13. def parse_txt_pdf(pdf_bytes:bytes, pdf_models:list, imageWriter: AbsReaderWriter, is_debug=False, start_page=0, *args, **kwargs):
  14. """
  15. 解析文本类pdf
  16. """
  17. pass
  18. def parse_ocr_pdf(pdf_bytes:bytes, pdf_models:list, imageWriter: AbsReaderWriter, is_debug=False, start_page=0, *args, **kwargs):
  19. """
  20. 解析ocr类pdf
  21. """
  22. pdf_info_dict = parse_pdf_by_ocr(
  23. pdf_bytes,
  24. pdf_models,
  25. imageWriter,
  26. start_page_id=start_page,
  27. debug_mode=is_debug,
  28. )
  29. return pdf_info_dict
  30. def parse_union_pdf(pdf_bytes:bytes, pdf_models:list, imageWriter: AbsReaderWriter, is_debug=False, start_page=0, *args, **kwargs):
  31. """
  32. ocr和文本混合的pdf,全部解析出来
  33. """
  34. pass