如何读取资源文件？ （谷歌云数据流）

Question

我的 Dataflow 管道需要读取资源文件 GeoLite2-City.mmdb。我将它添加到我的项目中并运行管道。我确认 GCS 上的暂存桶中存在项目包 zip 文件。

但是，当我尝试读取资源文件 GeoLite-City.mmdb 时，我得到了 FileNotFoundException。我怎样才能解决这个问题？这是我的代码：

String path = myClass.class.getResource("/GeoLite2-City.mmdb").getPath();

File database = new File(path);

try
{

DatabaseReader reader = new DatabaseReader.Builder(database).build(); //<-this line get a FileNotFoundException

}

catch (IOException e)

{

LOG.info(e.toString());

}

我的项目包压缩文件是“classes-WOdCPQCHjW-hRNtrfrnZMw.zip” （它包含类文件和GeoLite2-City.mmdb）

路径值为“file:/dataflow/packages/staging/classes-WOdCPQCHjW-hRNtrfrnZMw.zip!/GeoLite2-City.mmdb”，但无法打开。

这是选项。

--runner=BlockingDataflowPipelineRunner 
--project=peak-myproject 
--stagingLocation=gs://mybucket/staging 
--input=gs://mybucket_log/log.68599ca3.gz

目标是转换 GCS 上的日志文件，并将转换后的数据插入 BigQuery。 当我在本地运行时，成功导入 Bigquery。 我认为本地 PC 和 GCE 获取资源路径是有区别的。

Answer 1

我认为问题可能是DatabaseReader 不支持位于 .zip 或 .jar 文件中的资源的路径。

如果是这种情况，那么您的程序使用 DirectPipelineRunner 不是因为它是直接的，而是因为资源只是位于本地文件系统而不是 .zip 文件中（正如您的评论所说，路径是 @987654324 @，而在另一种情况下是file:/dataflow/packages/staging/classes-WOdCPQCHjW-hRNtrfrnZMw.zip!/GeoLite2-City.mmdb)

我在网上搜索了您可能在谈论的 DatabaseReader 类，似乎是https://github.com/maxmind/GeoIP2-java/blob/master/src/main/java/com/maxmind/geoip2/DatabaseReader.java。

在这种情况下，您的代码很可能会在以下微小更改下正常工作：

try
{
  InputStream stream = myClass.class.getResourceAsStream("/GeoLite2-City.mmdb");
  DatabaseReader reader = new DatabaseReader.Builder(stream).build();
}
catch (IOException e)
{
  ...
}