Conector de Cloud Storage

El conector de Cloud Storage es una biblioteca Java de código abierto que te permite ejecutar trabajos de Apache Hadoop o Apache Spark directamente en los datos en Cloud Storage y ofrece una serie de beneficios sobre el sistema de archivos distribuidos de Hadoop (HDFS).

Compatibilidad con conectores. El conector de Cloud Storage es compatible con Google Cloud para productos y casos prácticos de Google Cloud y cuando se usa con Dataproc es compatible con el mismo nivel que Dataproc (consulta la documentación sobre cómo obtener asistencia).

Beneficios del conector de Cloud Storage

• Acceso directo a los datos: Almacena tus datos en Cloud Storage y accede a ellos directamente. No es necesario que primero la transfieras a HDFS.
• Compatibilidad con HDFS: Puedes acceder fácilmente a tus datos en Cloud Storage con el prefijo gs:// en lugar de hdfs://.
• Interoperabilidad: El almacenamiento de datos en Cloud Storage permite una interoperabilidad perfecta entre los servicios de Spark, Hadoop y Google.
• Accesibilidad a los datos: Cuando cierras un clúster de Hadoop, a diferencia de HDFS, sigues teniendo acceso a tus datos en Cloud Storage.
• Alta disponibilidad de los datos: Los datos almacenados en Cloud Storage están altamente disponibles y replicados de forma global sin perder rendimiento.
• Sobrecarga de administración sin almacenamiento: A diferencia de HDFS, Cloud Storage no requiere mantenimiento de rutina, como revisar el sistema de archivos, actualizarlo o revertirlo a una versión anterior del sistema de archivos.
• Inicio rápido: En HDFS, un trabajo MapReduce no puede iniciarse hasta que el NameNode se encuentre fuera del modo seguro, un proceso que puede demorar unos pocos segundos o varios minutos, según el tamaño y el estado de tus datos. Con Cloud Storage, puedes comenzar tu trabajo en cuanto se inicien los nodos de tareas, lo que genera importantes ahorros de costos a lo largo del tiempo.

Obtén el conector

Clústeres de Dataproc

El conector de Cloud Storage se instala de forma predeterminada en todos los nodos del clúster de Dataproc en el directorio /usr/local/share/google/dataproc/lib/.

Nota: Cuando ejecutas el conector dentro de las VM de Compute Engine, incluidos los clústeres de Dataproc, google.cloud.auth.service.account.enable se configura como false de forma predeterminada, que significa que no necesitas configurar manualmente una cuenta de servicio para el conector. obtendrá automáticamente la credencial de la cuenta de servicio del servidor de metadatos de la VM. Sin embargo, solo debes asegurarte de que la cuenta de servicio de VM tenga permiso para acceder a tu bucket de Cloud Storage.

Si tu aplicación depende de una versión del conector diferente de la versión predeterminada del conector implementada en tu clúster de Dataproc, debes hacer lo siguiente:

1. Crea un clúster nuevo con la marca --metadata GCS_CONNECTOR_VERSION=x.y.z, que actualizará el conector que usa tu aplicación a la versión del conector especificada, o
2. incluir y reubicar las clases de conector y las dependencias de conector para la versión que usas en el archivo jar de tu aplicación, de modo que la versión de conector que usas no entre en conflicto con la versión de conector implementada en tu clúster de Dataproc (consulta este ejemplo de reubicación de dependencias en Maven).

Clústeres que no son de Dataproc

Puedes instalar y usar el Conector de Cloud Storage en un clúster de Apache Hadoop/Spark, por ejemplo, para mover datos HDFS locales a Cloud Storage

.

1. Descarga el conector.

   Si deseas descargar el conector de Cloud Storage para Hadoop, sigue estos pasos:

   • la última versión ubicada en el bucket de Cloud Storage (no se recomienda para su uso en producción):
     • Conector de Cloud Storage para Hadoop 1.x
     • Conector de Cloud Storage para Hadoop 2.x
     • Conector de Cloud Storage para Hadoop 3.x
   • versión específica del depósito de Cloud Storage mediante el reemplazo de las versiones del conector de Hadoop y Cloud Storage en el patrón del nombre gcs-connector-HADOOP_VERSION-CONNECTOR_VERSION.jar:
     • Ejemplo: gs://hadoop-lib/gcs/gcs-connector-hadoop2-2.1.1.jar
   • versión específica del repositorio de Apache Maven (debes descargar un jar sombreado con el sufijo -shaded en el nombre):
     • Conector de Cloud Storage para Hadoop 1.x
     • Conector de Cloud Storage para Hadoop 2.x
     • Conector de Cloud Storage para Hadoop 3.x

2. Instala el conector.

   Consulta Instala el conector en GitHub para instalar, configurar y probar el conector de Cloud Storage.

Usa el conector

Hay varias formas de acceder a los datos almacenados en Cloud Storage:

• En una aplicación Spark (o PySpark) o Hadoop con el prefijo gs://.
• La shell de Hadoop: hadoop fs -ls gs://bucket/dir/file.
• El navegador de Cloud Storage en Google Cloud Console.
• Usa los comandos gsutil cp o gsutil rsync.

Recursos

• Usa el conector de Cloud Storage con Apache Spark
• API de Apache Hadoop FileSystem

Versión de Java

El conector de Cloud Storage requiere Java 8.

Información sobre las dependencias de Apache Maven

<dependency>
    <groupId>com.google.cloud.bigdataoss</groupId>
    <artifactId>gcs-connector</artifactId>
    <version>insert "hadoopX-X.X.X" connector version number here</version>
    <scope>provided</scope>
</dependency>

o para la versión sombreada:

<dependency>
    <groupId>com.google.cloud.bigdataoss</groupId>
    <artifactId>gcs-connector</artifactId>
    <version>insert "hadoopX-X.X.X" connector version number here</version>
    <scope>provided</scope>
    <classifier>shaded</classifier>
</dependency>

Para obtener información más detallada, consulta las notas de la versión del conector de Cloud Storage y la referencia de Javadoc.

¿Qué sigue?

• Obtén más información sobre Cloud Storage