Classe IntToIp

La transformation IntToIp convertit la valeur entière de la colonne source ou d’une autre valeur en valeur IPv4 correspondante dans la colonne cible, puis renvoie le résultat dans une nouvelle colonne.

exemple

from pyspark.context import SparkContext
from pyspark.sql import SparkSession
from awsgluedi.transforms import *

sc = SparkContext()
spark = SparkSession(sc)

input_df = spark.createDataFrame(
    [
        (3221225473,),
        (0,),
        (1,),
        (100,),
        (168430090,),
        (4294967295,),
        (4294967294,),
        (4294967296,),
        (-1,),
        (None,),
    ],
    ["source_column_int"],
)

try:
    df_output = web_functions.IntToIp.apply(
        data_frame=input_df,
        spark_context=sc,
        source_column="source_column_int",
        target_column="target_column",
        value=None
    )
    df_output.show()
except:
    print("Unexpected Error happened ")
    raise
    

Sortie

Le résultat sera :

```
+---------------+---------------+
|source_column_int|target_column|
+---------------+---------------+
| 3221225473| 192.0.0.1 |
| 0| 0.0.0.0 |
| 1| 0.0.0.1 |
| 100| 0.0.0.100|
| 168430090 | 10.0.0.10 |
| 4294967295| 255.255.255.255|
| 4294967294| 255.255.255.254|
| 4294967296| null |
| -1| null |
| null| null |
+---------------+---------------+
```

La transformation IntToIp.apply prend la valeur `source_column` `"source_column_int"` et la valeur `target_column` `"target_column"` et convertit les valeurs entières de la colonne `source_column_int` en leur représentation d’adresse IPv4 correspondante et stocke le résultat dans la colonne `target_column`.

Pour les valeurs entières valides comprises dans la plage d’adresses IPv4 (0 à 4294967295), la transformation les convertit correctement en leur représentation d’adresse IPv4 (par exemple, 192.0.0.1, 0.0.0.0, 10.0.0.10, 255.255.255.255).

Pour les valeurs d’entier situées en dehors de la plage valide (par exemple, 4294967296, -1), la valeur `target_column` est définie sur `null`. Pour les valeurs `null` de la colonne `source_column_int`, la valeur `target_column` est également définie sur `null`.

Méthodes

__call__(spark_context, data_frame, target_column, source_column=None, value=None)

La transformation IntToIp convertit la valeur entière de la colonne source ou d’une autre valeur en valeur IPv4 correspondante dans la colonne cible, puis renvoie le résultat dans une nouvelle colonne.

apply(cls, *args, **kwargs)

Hérité de GlueTransform s'appliquent.

name(cls)

Hérité de GlueTransform name.

describeArgs(cls)

Hérité de GlueTransform describeArgs.

describeReturn(cls)

Hérité de GlueTransform describeReturn.

describeTransform(cls)

Hérité de GlueTransform describeTransform.

describeErrors(cls)

Hérité de GlueTransform describeErrors.

describe(cls)

Hérité de GlueTransform describe.