[JAVA] Êtes-vous toujours épuisé par la recherche d'exemples de vidéos? Un bouton pour envoyer des vidéos FANZA à Slack lorsque vous appuyez dessus.

Aperçu

• Lorsque vous appuyez sur le bouton AWS IoT Enterprise, vous obtenez l'URL de l'exemple de vidéo à partir de l'API de FANZA et l'envoyez à Slack au hasard, alors prenez note des détails techniques sous forme de mémorandum.

Objectif

• J'ai acheté AWS IoT chez Nori, alors essayez de l'utiliser.
• Je souhaite réduire le temps de recherche d'exemples de vidéos plusieurs fois par semaine.
• Je voulais développer AWS Lambda localement.
• Je voulais écrire Kotlin.

Cible

• Une personne qui souhaite utiliser AWS Lambda
• Les personnes souhaitant développer AWS Lambda tout en déboguant localement
• Les personnes qui souhaitent envoyer un message du programme à Slack
• ʻQui veut utiliser le bouton AWS IoT`
• Les personnes qui veulent écrire ʻAWS Lambda en Java`
• Les personnes qui veulent écrire ʻAWS Lambda dans Kotlin`
• Les personnes épuisées par la recherche d'exemples de vidéos

Tel.

Hypothèses (environnement, etc.)

• macOS : macOS Mojave 10.14.5
• «Vous avez acheté le bouton AWS IoT Enterprise».
• IntelliJ IDEA ultimate
• Docker installé (requis pour le développement local)
• L'API FANZA peut être atteinte (acquisition d'identifiant d'affilié DMM → acquisition d'identifiant d'API FANZA)

Code source

https://github.com/yu-suke-dev/fanza-bot

Créer un projet

Installation du plug-in

• Installez le plug-in ʻAWS ToolKit`.

Démarrez le projet

• Sélectionnez ʻAWS Setverless Application` pour démarrer le projet.

La hiérarchie du projet ressemble à ceci:

[sample]
   ├── HelloWorldFunction
   │   ├── build.gradle
   │   ├── gradle
   │   │   └── wrapper
   │   │       ├── gradle-wrapper.jar
   │   │       └── gradle-wrapper.properties
   │   ├── gradlew
   │   ├── gradlew.bat
   │   └── src
   │       ├── main
   │       │   └── java
   │       │       └── helloworld
   │       │           ├── App.java
   │       │           └── GatewayResponse.java
   │       └── test
   │           └── java
   │               └── helloworld
   │                   └── AppTest.java
   ├── README.md
   ├── sample.iml
   └── template.yaml

Remplacez par Kotlin.

• build.gradle

build.gradle

plugins {
    id 'org.jetbrains.kotlin.jvm' version '1.3.40'
}

apply plugin: 'kotlin'

repositories {
    mavenCentral()
}

sourceCompatibility = '1.8'
targetCompatibility = '1.8'

jar {
    manifest {
        attributes('Main-Class': 'fanza.App')
    }
    from { configurations.compile.collect { it.isDirectory() ? it : zipTree(it) } }
}

dependencies {
    compile "com.amazonaws:aws-lambda-java-core:1.2.0"
    compile "org.jetbrains.kotlin:kotlin-stdlib-jdk8:1.3.40"
    compile "com.squareup.okhttp3:okhttp:3.9.0"
    compile "org.json:json:20180813"
    testCompile "junit:junit:4.12"
}

• src Procédez comme suit:

[src]
  ├── main
  │   └── kotlin
  │       └── fanza
  │           └── App.java
  └── test
  │   └── java
  │       └── fanza
  │           └── AppTest.java

• App.kt

App.kt

package fanza

import com.amazonaws.services.lambda.runtime.Context
import com.amazonaws.services.lambda.runtime.RequestHandler
import okhttp3.MediaType
import okhttp3.OkHttpClient
import okhttp3.Request
import okhttp3.RequestBody
import org.json.JSONObject
import java.io.IOException

/**
 * Handler for requests to Lambda function.
 */
class App : RequestHandler<Any, Any> {

    /**
     * called method
     */
    override fun handleRequest(input: Any, context: Context): Any {

        try {
            //ID requis pour l'API fanza
            var fanzaApiId = System.getenv("FANZA_API_ID")
            var affiliateId = System.getenv("FANZA_AFFILIATE_ID")

            //Créez l'URL que vous souhaitez rechercher
            val fanzaUrl: String = "https://api.dmm.com/affiliate/v3/ItemList"
                    .plus("?api_id=$fanzaApiId")
                    .plus("&affiliate_id=$affiliateId")
                    .plus("&site=FANZA&service=digital&floor=videoa")
                    .plus("&hits=20&sort=date&keyword=amateur&output=json")

            //ACCÉDER À FANZA
            val fanzaInfo = get(fanzaUrl).replace("\\", "")

            //Expression régulière de la partie que vous souhaitez extraire
            val regex = Regex("https://www.dmm.co.jp/litevideo/-/part/=/cid=[a-z]{3,5}[0-9]{3,5}/size=720_480/")

            //Extrayez-en un au hasard des résultats extraits
            val result: String = regex.findAll(fanzaInfo)
                    .map { it.value }
                    .toList()
                    .random()

            //URL du Webhook Slack
            var slackUrl: String = System.getenv("SLACK_URL")

            //Quoi envoyer à Slack
            var slackJson = JSONObject()
            slackJson.put("channel", "#fanza")
            slackJson.put("username", "fanza-bot")
            slackJson.put("text", result)
            slackJson.put("icon_emoji", ":womens:")

            //post envoyer
            post(slackUrl, slackJson.toString())

            return "Success"

        } catch (e: IOException) {
            return RuntimeException(e)
        }
    }

    /**
     * get
     */
    @Throws(IOException::class)
    operator fun get(url: String): String {
        val request = Request.Builder()
                .url(url)
                .header("Content-Type", "application/json")
                .addHeader("X-Custom-Header", "application/json")
                .build()
        val client = OkHttpClient.Builder().build()
        val response = client.newCall(request).execute()
        return response.body()!!.string()
    }

    /**
     * post
     */
    @Throws(IOException::class)
    fun post(url: String, json: String): String {
        val body = RequestBody
                .create(MediaType.parse("application/json; charset=utf-8"), json)
        val request = Request.Builder()
                .url(url)
                .put(body)
                .build()
        val client = OkHttpClient()
        return client.newCall(request).execute().body()!!.string()
    }
}

Définition des variables d'environnement

Contrôle de fonctionnement

Résultat d'exécution

• Si Slack reçoit une notification réussie et que la console affiche ce qui suit, cela signifie que l'opération réussit.

Créer un fichier Jar

• Lorsque vous avez terminé, créez un fichier Jar.

gradle jar

Transférer vers Lambda

• Variable d'environnement: définir la même chose que celle définie localement.
• Téléchargez le fichier Jar créé ci-dessus.

Lier AWS IoT Button et AWS Lambda

• Enregistrer le produit: omis. Enregistrez le produit en vous référant aux articles suivants. 　https://qiita.com/shogo_m/items/9aa7b400a031e8503e7f

• Créer un projet: sélectionnez ʻIoT 1-Click` sur l'écran de la console AWS

• Spécifier le nom du projet

• Spécifiez la fonction Lambda créée ici.

Résultat d'exécution

Appuie sur le bouton. (Pochi)

• Vérifiez le résultat de l'exécution dans Slack.

Résumé

• Cette fois, j'ai essayé uniquement l'opération en 1 clic.
• L'obtention de l'URL du Webhook Slack est omise.
• Pour Java, essayez de le remplacer par Java.
• Cette fois, j'ai défini la variable d'environnement dans Lambda, mais il est plus sûr de la définir dans AWS KMS.
• Le code de test, les journaux, etc. sont médiocres, je voudrais donc les refactoriser si j'ai le temps.

Article référencé (Merci)

• https://qiita.com/naokiur/items/548fc01240c2488de15c
• https://qiita.com/shogo_m/items/9aa7b400a031e8503e7f